summaryrefslogtreecommitdiff
path: root/plugins/websockets/rpc.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-05-28 13:19:02 +0300
committerValery Piashchynski <[email protected]>2021-05-28 13:19:02 +0300
commit0a64bb2a71ddb6b0ee5861e255a20df1327aa099 (patch)
tree98a607f517706174215b92be8f337d21f918b955 /plugins/websockets/rpc.go
parent5527b31b2da2b60ed8877b8c43badb73f98ec7bb (diff)
- Tests for the ws-redis, ws-memory
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/websockets/rpc.go')
-rw-r--r--plugins/websockets/rpc.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/plugins/websockets/rpc.go b/plugins/websockets/rpc.go
index 2b3ae54e..f917bd53 100644
--- a/plugins/websockets/rpc.go
+++ b/plugins/websockets/rpc.go
@@ -14,6 +14,7 @@ type rpc struct {
func (r *rpc) Publish(msg []*pubsub.Msg, ok *bool) error {
const op = errors.Op("broadcast_publish")
+ r.log.Debug("message published", "msg", msg)
// publish to the registered broker
mi := make([]pubsub.Message, 0, len(msg))