Repository: activemq Updated Branches: refs/heads/master 9ec6ee43b -> ba7934e91
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. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/ba7934e9 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/ba7934e9 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/ba7934e9 Branch: refs/heads/master Commit: ba7934e91adf1c068db7107a6353b867e276affb Parents: 9ec6ee4 Author: Timothy Bish <[email protected]> Authored: Wed Aug 1 18:34:09 2018 -0400 Committer: Timothy Bish <[email protected]> Committed: Wed Aug 1 18:34:09 2018 -0400 ---------------------------------------------------------------------- .../transport/amqp/message/JMSMappingOutboundTransformer.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/ba7934e9/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java ---------------------------------------------------------------------- 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 f3db5e4..346a54c 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<String, Object> 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)) {
