diff --git a/pkg/microservice/messaging/nats.go b/pkg/microservice/messaging/nats.go index 2da32f84..38e570eb 100644 --- a/pkg/microservice/messaging/nats.go +++ b/pkg/microservice/messaging/nats.go @@ -73,7 +73,7 @@ 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, + Name: name, DeliverPolicy: jetstream.DeliverByStartTimePolicy, OptStartTime: &messageStartTime, AckPolicy: jetstream.AckNonePolicy,