From 2dd18c2b70d67cc0876a00eb8c4714eb5ff50a7f Mon Sep 17 00:00:00 2001
From: mackristof <christophe@mourette.eu>
Date: Tue, 28 Jun 2016 22:07:54 +0200
Subject: [PATCH] fix(cluster): change HazelcastMsg payload to byte[]

---
 .../main/java/io/moquette/interception/HazelcastMsg.java    | 6 +++---
 .../src/main/java/io/moquette/server/HazelcastListener.java | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/broker/src/main/java/io/moquette/interception/HazelcastMsg.java b/broker/src/main/java/io/moquette/interception/HazelcastMsg.java
index 61f4ca20..6ba7deeb 100644
--- a/broker/src/main/java/io/moquette/interception/HazelcastMsg.java
+++ b/broker/src/main/java/io/moquette/interception/HazelcastMsg.java
@@ -10,13 +10,13 @@ public class HazelcastMsg implements Serializable{
     private final String clientId;
     private final String userName;
     private final byte qos;
-    private final String payload;
+    private final byte[] payload;
     private final String topic;
 
     public HazelcastMsg(String clientId, String topic , byte qos, byte[] payload, String userName) {
         this.clientId = clientId;
         this.qos = qos;
-        this.payload = new String(payload);
+        this.payload = payload;
         this.userName = userName;
         this.topic = topic;
     }
@@ -30,7 +30,7 @@ public class HazelcastMsg implements Serializable{
         return qos;
     }
 
-    public String getPayload() {
+    public byte[] getPayload() {
         return payload;
     }
 
diff --git a/broker/src/main/java/io/moquette/server/HazelcastListener.java b/broker/src/main/java/io/moquette/server/HazelcastListener.java
index 64acad59..7a3f13cf 100644
--- a/broker/src/main/java/io/moquette/server/HazelcastListener.java
+++ b/broker/src/main/java/io/moquette/server/HazelcastListener.java
@@ -32,7 +32,7 @@ public class HazelcastListener implements MessageListener<HazelcastMsg> {
                 PublishMessage publishMessage = new PublishMessage();
                 publishMessage.setTopicName(msg.getMessageObject().getTopic());
                 publishMessage.setQos(AbstractMessage.QOSType.valueOf(msg.getMessageObject().getQos()));
-                publishMessage.setPayload(ByteBuffer.wrap(msg.getMessageObject().getPayload().getBytes("UTF-8")));
+                publishMessage.setPayload(ByteBuffer.wrap(msg.getMessageObject().getPayload()));
                 publishMessage.setLocal(false);
                 publishMessage.setClientId(msg.getMessageObject().getClientId());
                 server.internalPublish(publishMessage);