Remove stream creation

DIMO-Network · Sep 12, 2023 · 7c7aea4 · 7c7aea4
1 parent 7a297f1
commit 7c7aea4
Showing 1 changed file with 0 additions and 10 deletions.
diff --git a/internal/services/nats_service.go b/internal/services/nats_service.go
@@ -30,16 +30,6 @@ func NewNATSService(settings *config.Settings, log *zerolog.Logger) (*NATSServic
 		return nil, err
 	}
 
-	_, err = js.AddStream(&nats.StreamConfig{
-		Name:      settings.NATSStreamName,
-		Retention: nats.WorkQueuePolicy,
-		Subjects:  []string{settings.NATSValuationSubject},
-	})
-
-	if err != nil {
-		return nil, err
-	}
-
 	to, err := time.ParseDuration(settings.NATSAckTimeout)
 	if err != nil {
 		return nil, err