Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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.
This commit is contained in:
Timothy Bish 2018-08-01 18:34:09 -04:00
parent 9ec6ee43b1
commit ba7934e91a
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java
View File

@ -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.AMQPDefinedTypes;
import org.apache.qpid.proton.codec.DecoderImpl; import org.apache.qpid.proton.codec.DecoderImpl;
import org.apache.qpid.proton.codec.EncoderImpl; import org.apache.qpid.proton.codec.EncoderImpl;
import org.fusesource.hawtbuf.UTF8Buffer;
public class JMSMappingOutboundTransformer implements OutboundTransformer { public class JMSMappingOutboundTransformer implements OutboundTransformer {
@ -256,9 +255,6 @@ public class JMSMappingOutboundTransformer implements OutboundTransformer {
for (Map.Entry<String, Object> entry : entries.entrySet()) { for (Map.Entry<String, Object> entry : entries.entrySet()) {
String key = entry.getKey(); String key = entry.getKey();
Object value = entry.getValue(); Object value = entry.getValue();
if (value instanceof UTF8Buffer) {
value = value.toString();
}
if (key.startsWith(JMS_AMQP_PREFIX)) { if (key.startsWith(JMS_AMQP_PREFIX)) {
if (key.startsWith(NATIVE, JMS_AMQP_PREFIX_LENGTH)) { if (key.startsWith(NATIVE, JMS_AMQP_PREFIX_LENGTH)) {