fix: make nats consumer durable with cleanup after one week (nameserv…

…er-systems#363)
linxside · Mar 17, 2024 · 824712b · 824712b
1 parent 4d938fb
commit 824712b
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/pkg/microservice/messaging/nats.go b/pkg/microservice/messaging/nats.go
@@ -73,11 +73,13 @@ func (nb *natsBroker) CreatePersistentMessageReceiver(name, id, address, port, c
 	messageStartTime := time.Now().Add(-15 * time.Minute).Round(time.Minute)
 
 	cfg := jetstream.ConsumerConfig{
-		Name:          name + id,
-		DeliverPolicy: jetstream.DeliverByStartTimePolicy,
-		OptStartTime:  &messageStartTime,
-		AckPolicy:     jetstream.AckNonePolicy,
-		Metadata:      map[string]string{"id": id, "address": address, "port": port, "type": cType},
+		Name:              name + id,
+		Durable:           name + id,
+		InactiveThreshold: 8 * 24 * time.Hour,
+		DeliverPolicy:     jetstream.DeliverByStartTimePolicy,
+		OptStartTime:      &messageStartTime,
+		AckPolicy:         jetstream.AckNonePolicy,
+		Metadata:          map[string]string{"id": id, "address": address, "port": port, "type": cType},
 	}
 
 	consumer, err := stream.CreateOrUpdateConsumer(ctx, cfg)