From 93abb12cfa1cbb154323ef2b2aeb2749e4bbcf6d Mon Sep 17 00:00:00 2001 From: watsonb8 Date: Tue, 26 Sep 2023 13:49:10 -0500 Subject: [PATCH] WIP --- internal/dispatcher/dispatcher.go | 1 + 1 file changed, 1 insertion(+) 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()