From 53417cbe037e803bb0dede0395a9b84223f35674 Mon Sep 17 00:00:00 2001 From: ajiththnn Date: Mon, 27 Jan 2020 17:43:31 +0530 Subject: [PATCH] pubnub set property channel --- protocols/sub/pubnub.go | 1 + 1 file changed, 1 insertion(+) diff --git a/protocols/sub/pubnub.go b/protocols/sub/pubnub.go index c28a1a1..6867f67 100644 --- a/protocols/sub/pubnub.go +++ b/protocols/sub/pubnub.go @@ -147,6 +147,7 @@ func (sub *PubnubSubscriber) receive(ec chan error) { func (sub *PubnubSubscriber) handleMessage(ec chan error) { for message := range sub.processChannel { + message.SetProperty("channel", sub.pubnubConfig.Topic) sub.callback(message) if val, ok := message.GetProperty("ack"); ok && val == "OK" { err := sub.setLastTime()