diff --git a/internal/dispatcher/dispatcher.go b/internal/dispatcher/dispatcher.go index a87a5ff..cd85f70 100644 --- 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()