WIP

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()