Fixed leaky subscription when getting sequence history

hiphops-io · Nov 23, 2023 · 3a8ee33 · 3a8ee33
1 parent 57b309a
commit 3a8ee33
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/nats/client.go b/nats/client.go
@@ -191,6 +191,9 @@ func (c *Client) FetchMessageBundle(ctx context.Context, newMsg *MsgMeta) (Messa
 	msgBundle := MessageBundle{}
 
 	msgCtx, err := cons.Messages()
+	if msgCtx != nil {
+		defer msgCtx.Stop()
+	}
 	if err != nil {
 		return nil, fmt.Errorf("Unable to read back messages: %w", err)
 	}