WIP

Fixing error where connection was re-established incorrectly
2023-09-26 13:49:10 -05:00 · 2023-09-26 13:43:34 -05:00
1 changed files with 1 additions and 0 deletions
--- a/internal/dispatcher/dispatcher.go
+++ b/internal/dispatcher/dispatcher.go
@ -127,6 +127,7 @@ 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()
Author	SHA1	Message	Date
watsonb8	93abb12cfa	WIP	2023-09-26 13:49:10 -05:00
watsonb8	e41fdd3561	Fixing error where connection was re-established incorrectly	2023-09-26 13:43:34 -05:00