Fixing error where connection was re-established incorrectly

2023-09-25 15:25:43 -05:00
1 changed files with 0 additions and 1 deletions
--- a/internal/dispatcher/dispatcher.go
+++ b/internal/dispatcher/dispatcher.go
@ -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()