diff options
Diffstat (limited to 'plugins/websockets/executor/executor.go')
| -rw-r--r-- | plugins/websockets/executor/executor.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/plugins/websockets/executor/executor.go b/plugins/websockets/executor/executor.go index 97293d52..1aa54be9 100644 --- a/plugins/websockets/executor/executor.go +++ b/plugins/websockets/executor/executor.go @@ -63,6 +63,7 @@ func (e *Executor) StartCommandLoop() error { //nolint:gocognit switch msg.Command() { // handle leave case commands.Join: + e.log.Debug("get join command", "msg", msg) // associate connection with topics e.storage.InsertMany(e.connID, msg.Topics()) @@ -96,6 +97,7 @@ func (e *Executor) StartCommandLoop() error { //nolint:gocognit // handle leave case commands.Leave: + e.log.Debug("get leave command", "msg", msg) // remove associated connections from the storage e.storage.RemoveMany(e.connID, msg.Topics()) |