move skip logic to serializer

Signed-off-by: MregXN <[email protected]>

sdk/src/main/java/io/dapr/client/DaprClientHttp.java

@@ -165,23 +165,13 @@ public Mono<Void> publishEvent(PublishEventRequest request) {
       Object data = request.getData();
       Map<String, String> metadata = request.getMetadata();
 
+      byte[] serializedEvent = objectSerializer.serialize(data);
       // Content-type can be overwritten on a per-request basis.
       // It allows CloudEvents to be handled differently, for example.
       String contentType = request.getContentType();
       if (contentType == null || contentType.isEmpty()) {
         contentType = objectSerializer.getContentType();
       }
-
-      byte[] serializedEvent;
-      if (contentType.equals("text/plain")) 
-      {
-        serializedEvent = ((String)data).getBytes();
-      }
-      else
-      {
-        serializedEvent = objectSerializer.serialize(data);
-      }
-
       Map<String, String> headers = Collections.singletonMap("content-type", contentType);
 
       String[] pathSegments = new String[]{ DaprHttp.API_VERSION, "publish", pubsubName, topic };

sdk/src/main/java/io/dapr/client/ObjectSerializer.java

@@ -69,6 +69,10 @@ public byte[] serialize(Object state) throws IOException {
       return ((MessageLite) state).toByteArray();
     }
 
+    if(state instanceof String) {
+      return ((String)state).getBytes();
+    }
+
     // Not string, not primitive, so it is a complex type: we use JSON for that.
     return OBJECT_MAPPER.writeValueAsBytes(state);
   }