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()
 	}
 }