Change rettention policy

2026-03-01 13:39:02 -05:00
parent b197791509
commit 83e257a4d5
1 changed files with 1 additions and 1 deletions
--- a/pkg/cmds/serve.go
+++ b/pkg/cmds/serve.go
@@ -144,7 +144,7 @@ func serve(ctx *cli.Context) error {
 	_, err = js.AddStream(&nats.StreamConfig{
 		Name:      "maptest",
 		Subjects:  []string{"maptest.>"},
-		Retention: nats.WorkQueuePolicy,
+		Retention: nats.InterestPolicy,
 	})
 	if err != nil {
 		log.WithError(err).Fatal("failed to add stream")