Convert ByteMessage correctly, use getData() method

solace-iot-team · Aug 17, 2020 · 0eada41 · 0eada41
1 parent d9d572d
commit 0eada41
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/com/solace/connector/mulesoft/jcsmp/util/MessageConverter.java b/src/main/java/com/solace/connector/mulesoft/jcsmp/util/MessageConverter.java
@@ -152,6 +152,9 @@ private TypedValue<Object> convertFromBytesMessage(BytesXMLMessage msg, String c
 			encoding = "utf-8";
 		}
 		byte[] bytesPayload = msg.getBytes();
+		if (msg instanceof BytesMessage) {
+			bytesPayload = ((BytesMessage) msg).getData();
+		}
 		if (!StringUtils.isBlank(mediaType))
 			dt = DataType.builder().type(String.class).mediaType(mediaType).charset(encoding).build();
 		else