diff --git a/src/main/java/com/ibm/eventstreams/connect/mqsource/builders/DefaultRecordBuilder.java b/src/main/java/com/ibm/eventstreams/connect/mqsource/builders/DefaultRecordBuilder.java
index 8d67a2b..4f4fce3 100755
--- a/src/main/java/com/ibm/eventstreams/connect/mqsource/builders/DefaultRecordBuilder.java
+++ b/src/main/java/com/ibm/eventstreams/connect/mqsource/builders/DefaultRecordBuilder.java
@@ -60,15 +60,16 @@ public DefaultRecordBuilder() {
         Object value = null;
 
         // Interpreting the body as a JMS message type, we can accept BytesMessage and TextMessage only.
-        // We do not know the schema so do not specify one.
         if (messageBodyJms) {
             if (message instanceof BytesMessage) {
-                log.debug("Bytes message with no schema");
+                log.debug("Bytes message. Setting bytes schema");
                 value = message.getBody(byte[].class);
+                valueSchema = Schema.BYTES_SCHEMA;
             }
             else if (message instanceof TextMessage) {
-                log.debug("Text message with no schema");
+                log.debug("Text message. Setting string schema");
                 value = message.getBody(String.class);
+                valueSchema = Schema.STRING_SCHEMA;
             }
             else {
                 log.error("Unsupported JMS message type {}", message.getClass());