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

https://issues.apache.org/jira/browse/AMQ-5737 

lookup transformer using case insensitive compare.
This commit is contained in:
Timothy Bish 2015-04-21 15:58:06 -04:00
parent 45eecf3351
commit ff1a1c4985
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java
View File

@ -141,11 +141,11 @@ public class AmqpReceiver extends AmqpAbstractReceiver {
protected InboundTransformer getInboundTransformer() { protected InboundTransformer getInboundTransformer() {
if (inboundTransformer == null) { if (inboundTransformer == null) {
String transformer = session.getConnection().getConfiguredTransformer(); String transformer = session.getConnection().getConfiguredTransformer();
if (transformer.equals(InboundTransformer.TRANSFORMER_JMS)) { if (transformer.equalsIgnoreCase(InboundTransformer.TRANSFORMER_JMS)) {
inboundTransformer = new JMSMappingInboundTransformer(ActiveMQJMSVendor.INSTANCE); inboundTransformer = new JMSMappingInboundTransformer(ActiveMQJMSVendor.INSTANCE);
} else if (transformer.equals(InboundTransformer.TRANSFORMER_NATIVE)) { } else if (transformer.equalsIgnoreCase(InboundTransformer.TRANSFORMER_NATIVE)) {
inboundTransformer = new AMQPNativeInboundTransformer(ActiveMQJMSVendor.INSTANCE); inboundTransformer = new AMQPNativeInboundTransformer(ActiveMQJMSVendor.INSTANCE);
} else if (transformer.equals(InboundTransformer.TRANSFORMER_RAW)) { } else if (transformer.equalsIgnoreCase(InboundTransformer.TRANSFORMER_RAW)) {
inboundTransformer = new AMQPRawInboundTransformer(ActiveMQJMSVendor.INSTANCE); inboundTransformer = new AMQPRawInboundTransformer(ActiveMQJMSVendor.INSTANCE);
} else { } else {
LOG.warn("Unknown transformer type {} using native one instead", transformer); LOG.warn("Unknown transformer type {} using native one instead", transformer);