From 6c8e116a0ef63c78dce31f63b22684040b71f835 Mon Sep 17 00:00:00 2001 From: holstad Date: Wed, 26 Oct 2022 11:38:34 +0200 Subject: [PATCH] Enforce schema for known data types --- .../connect/mqsource/builders/DefaultRecordBuilder.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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());