jhot
/
hats
1
0
Fork 0
Code Actions

Drain instead of close

main v0.18.3
Jordan Hotmann 2023-12-17 04:33:54 -07:00
parent 1d1e371113
commit 5a23359294
No known key found for this signature in database
GPG Key ID: 01B504170C2A2EA3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/nats/client.go
View File

@ -75,7 +75,7 @@ func (n *NatsConnection) Connect() error {
func (n *NatsConnection) Close() { func (n *NatsConnection) Close() {
if n.Conn != nil { if n.Conn != nil {
n.Conn.Close() n.Conn.Drain()
} }
} }