pubnub set property channel

amagimedia · Jan 27, 2020 · 53417cb · 53417cb
1 parent ea88afa
commit 53417cb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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()