diff options
Diffstat (limited to 'plugins/redis')
| -rw-r--r-- | plugins/redis/fanin.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/plugins/redis/fanin.go b/plugins/redis/fanin.go index 29016720..8e924b2d 100644 --- a/plugins/redis/fanin.go +++ b/plugins/redis/fanin.go @@ -56,9 +56,9 @@ func (fi *FanIn) AddChannel(topics ...string) error { func (fi *FanIn) read() { for { select { - //here we receive message from us (which we sent before in Publish) - //it should be compatible with the websockets.Msg interface - //payload should be in the redis.message.payload field + // here we receive message from us (which we sent before in Publish) + // it should be compatible with the websockets.Msg interface + // payload should be in the redis.message.payload field case msg, ok := <-fi.pubsub.Channel(): // channel closed |