use DeliverAllPolicy for system private

mynaparrot · Sep 27, 2024 · 22c46be · 22c46be
1 parent cf99167
commit 22c46be
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/services/nats/js_consumer.go b/pkg/services/nats/js_consumer.go
@@ -50,8 +50,7 @@ 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),
-		DeliverPolicy: jetstream.DeliverNewPolicy,
+		Name: fmt.Sprintf("%s:%s", s.app.NatsInfo.Subjects.SystemPrivate, userId),
 		FilterSubjects: []string{
 			fmt.Sprintf("%s:%s.%s.>", roomId, s.app.NatsInfo.Subjects.SystemPrivate, userId),
 		},