Optimize serialization when JsonNode is passed in Emit & Publish args

Author: XDex

.idea/modules/SocketclusterClientJava.iml

@@ -37,7 +37,7 @@ allprojects {
 ...
 
 dependencies {
-    implementation 'com.github.XDex:socketcluster-client-java:2.0.1'
+    implementation 'com.github.XDex:socketcluster-client-java:2.0.2'
 }
 ```
 

.idea/modules/SocketclusterClientJava_main.iml

@@ -12,7 +12,7 @@ allprojects {
 }
 
 group = 'com.github.XDex'
-version = '2.0.1'
+version = '2.0.2'
 
 allprojects {
     repositories {

.idea/modules/SocketclusterClientJava_test.iml

@@ -242,25 +242,33 @@ public void onSendError(WebSocket websocket, WebSocketException cause, WebSocket
 
     }
 
-    public Socket emit(final String event, final Object object) {
+    private void setDataField(ObjectNode object, Object data) {
+        if (data instanceof JsonNode) {
+            object.set("data", (JsonNode) data);
+        } else {
+            object.putPOJO("data", data);
+        }
+    }
+
+    public Socket emit(final String event, final Object data) {
         EventThread.exec(new Runnable() {
             public void run() {
                 ObjectNode eventObject = mapper.createObjectNode();
                 eventObject.put("event", event);
-                eventObject.putPOJO("data", object);
+                setDataField(eventObject, data);
                 send(eventObject);
             }
         });
         return this;
     }
 
-    public Socket emit(final String event, final Object object, final Ack ack) {
+    public Socket emit(final String event, final Object data, final Ack ack) {
         EventThread.exec(new Runnable() {
             public void run() {
                 ObjectNode eventObject = mapper.createObjectNode();
                 acks.put(counter.longValue(), getAckObject(event, ack));
                 eventObject.put("event", event);
-                eventObject.putPOJO("data", object);
+                setDataField(eventObject, data);
                 eventObject.put("cid", counter.getAndIncrement());
                 send(eventObject);
             }
@@ -337,7 +345,7 @@ public void run() {
 
                 ObjectNode dataObject = mapper.createObjectNode();
                 dataObject.put("channel", channel);
-                dataObject.putPOJO("data", data);
+                setDataField(dataObject, data);
                 publishObject.set("data", dataObject);
 
                 publishObject.put("cid", counter.getAndIncrement());
@@ -357,7 +365,7 @@ public void run() {
                 ObjectNode dataObject = mapper.createObjectNode();
                 acks.put(counter.longValue(), getAckObject(channel, ack));
                 dataObject.put("channel", channel);
-                dataObject.putPOJO("data", data);
+                setDataField(dataObject, data);
                 publishObject.set("data", dataObject);
 
                 publishObject.put("cid", counter.getAndIncrement());