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()