diff options
Diffstat (limited to 'plugins/redis/pubsub/channel.go')
| -rw-r--r-- | plugins/redis/pubsub/channel.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/redis/pubsub/channel.go b/plugins/redis/pubsub/channel.go index eef5a7b9..a1655ab2 100644 --- a/plugins/redis/pubsub/channel.go +++ b/plugins/redis/pubsub/channel.go @@ -92,6 +92,6 @@ func (r *redisChannel) stop() error { return nil } -func (r *redisChannel) message() *pubsub.Message { - return <-r.out +func (r *redisChannel) message() chan *pubsub.Message { + return r.out } |