use DeliverNewPolicy

mynaparrot · Sep 30, 2024 · f4054c0 · f4054c0
1 parent 706412c
commit f4054c0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/services/nats/js_consumer.go b/pkg/services/nats/js_consumer.go
@@ -50,7 +50,8 @@ func (s *NatsService) CreateSystemPublicConsumer(roomId, userId string) (jwt.Str
 
 func (s *NatsService) CreateSystemPrivateConsumer(roomId, userId string) (jwt.StringList, error) {
 	_, err := s.js.CreateOrUpdateConsumer(s.ctx, roomId, jetstream.ConsumerConfig{
-		Name: fmt.Sprintf("%s:%s", s.app.NatsInfo.Subjects.SystemPrivate, userId),
+		Name:          fmt.Sprintf("%s:%s", s.app.NatsInfo.Subjects.SystemPrivate, userId),
+		DeliverPolicy: jetstream.DeliverNewPolicy,
 		FilterSubjects: []string{
 			fmt.Sprintf("%s:%s.%s.>", roomId, s.app.NatsInfo.Subjects.SystemPrivate, userId),
 		},