mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-17 11:24:44 -07:00
Merge pull request #44 from fraenkel/stale_reconnect
Let readLoop do the closeConnection magic on any error
This commit is contained in:
@@ -832,7 +832,6 @@ func (c *client) clearConnection() {
|
||||
}
|
||||
c.bw.Flush()
|
||||
c.nc.Close()
|
||||
c.nc = nil
|
||||
}
|
||||
|
||||
func (c *client) typeString() string {
|
||||
@@ -859,6 +858,7 @@ func (c *client) closeConnection() {
|
||||
c.clearAuthTimer()
|
||||
c.clearPingTimer()
|
||||
c.clearConnection()
|
||||
c.nc = nil
|
||||
|
||||
// Snapshot for use.
|
||||
subs := c.subs.All()
|
||||
|
||||
Reference in New Issue
Block a user