diff --git a/index.js b/index.js
index 0c25c00..8619c4b 100644
--- a/index.js
+++ b/index.js
@@ -74,7 +74,9 @@ module.exports.attach = function (broker, options) {
       } else {
         data = message.slice(2);
       }
-      broker.publish(channel, data);
+      broker.publish(channel, {
+        messages: [data]
+      });
     }
   });
 };
\ No newline at end of file