Compare commits

..

1 Commits

Author SHA1 Message Date
12bd5e6a01 Fixing error where connection was re-established incorrectly 2023-09-25 15:25:43 -05:00

View File

@ -127,7 +127,6 @@ func (d *Dispatcher) dispatchMessage(msg *message.Message) {
sub := subsList[i]
d.Subscribe(sub.Name(), sub.AuthToken())
}
case message.MetaSubscribe:
//handle MetaSubscribe resp
d.pendingSubsMu.Lock()