diff --git a/asb-native/src/main/java/org/ballerinax/asb/receiver/MessageReceiver.java b/asb-native/src/main/java/org/ballerinax/asb/receiver/MessageReceiver.java
index 2af24571..3e5afb60 100644
--- a/asb-native/src/main/java/org/ballerinax/asb/receiver/MessageReceiver.java
+++ b/asb-native/src/main/java/org/ballerinax/asb/receiver/MessageReceiver.java
@@ -53,6 +53,7 @@
 
 import org.apache.log4j.Level;
 import org.apache.log4j.Logger;
+import org.apache.qpid.proton.amqp.Binary;
 import org.ballerinax.asb.util.ASBConstants;
 import org.ballerinax.asb.util.ASBUtils;
 import org.ballerinax.asb.util.ModuleUtils;
@@ -199,6 +200,8 @@ public Object convertAMQPToJava(String messageId, Object amqpValue) {
                 return (java.util.Date) amqpValue;
             case "UUID":
                 return (UUID) amqpValue;
+            case "Binary":
+                return ((Binary) amqpValue).getArray();
             default:
                 log.debug("The type of amqpValue object " + clazz + " is not supported");
                 return null;