From ba7934e91adf1c068db7107a6353b867e276affb Mon Sep 17 00:00:00 2001 From: Timothy Bish Date: Wed, 1 Aug 2018 18:34:09 -0400 Subject: [PATCH] AMQ-7001 Remove now unnecessary check for UTF8Buffer type Remove the now unneeded checks for UTF8Buffer on the outbound converter as the Codec now can encode those to the correct string AMQP types without need for any help. --- .../transport/amqp/message/JMSMappingOutboundTransformer.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java index f3db5e4eca..346a54c985 100644 --- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java +++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java @@ -88,7 +88,6 @@ import org.apache.qpid.proton.amqp.messaging.Section; import org.apache.qpid.proton.codec.AMQPDefinedTypes; import org.apache.qpid.proton.codec.DecoderImpl; import org.apache.qpid.proton.codec.EncoderImpl; -import org.fusesource.hawtbuf.UTF8Buffer; public class JMSMappingOutboundTransformer implements OutboundTransformer { @@ -256,9 +255,6 @@ public class JMSMappingOutboundTransformer implements OutboundTransformer { for (Map.Entry entry : entries.entrySet()) { String key = entry.getKey(); Object value = entry.getValue(); - if (value instanceof UTF8Buffer) { - value = value.toString(); - } if (key.startsWith(JMS_AMQP_PREFIX)) { if (key.startsWith(NATIVE, JMS_AMQP_PREFIX_LENGTH)) {