Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-06 01:59:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

AMQ-7001 Remove now unnecessary check for UTF8Buffer type

Browse Source 
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.

(cherry picked from commit ba7934e91adf1c068db7107a6353b867e276affb)
This commit is contained in:
Timothy Bish 2018-08-01 18:34:09 -04:00
parent ad0ae74f3b
commit 77e584f057
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.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)) {