From 5a233592942064aeaddc9560bfe7f7d6b0a6a90d Mon Sep 17 00:00:00 2001
From: Jordan Hotmann <jhot@protonmail.com>
Date: Sun, 17 Dec 2023 04:33:54 -0700
Subject: [PATCH] Drain instead of close

---
 pkg/nats/client.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/nats/client.go b/pkg/nats/client.go
index 264dd8f..c9c6faa 100644
--- a/pkg/nats/client.go
+++ b/pkg/nats/client.go
@@ -75,7 +75,7 @@ func (n *NatsConnection) Connect() error {
 
 func (n *NatsConnection) Close() {
 	if n.Conn != nil {
-		n.Conn.Close()
+		n.Conn.Drain()
 	}
 }