diff options
| author | Valery Piashchynski <[email protected]> | 2021-05-28 13:19:02 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-05-28 13:19:02 +0300 |
| commit | 0a64bb2a71ddb6b0ee5861e255a20df1327aa099 (patch) | |
| tree | 98a607f517706174215b92be8f337d21f918b955 /plugins/websockets/executor | |
| parent | 5527b31b2da2b60ed8877b8c43badb73f98ec7bb (diff) | |
- Tests for the ws-redis, ws-memory
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/websockets/executor')
| -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()) |