Repository: activemq Updated Branches: refs/heads/master 45eecf335 -> ff1a1c498
https://issues.apache.org/jira/browse/AMQ-5737 lookup transformer using case insensitive compare. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/ff1a1c49 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/ff1a1c49 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/ff1a1c49 Branch: refs/heads/master Commit: ff1a1c49857de8243b21d454f520ac103760a15b Parents: 45eecf3 Author: Timothy Bish <[email protected]> Authored: Tue Apr 21 15:58:06 2015 -0400 Committer: Timothy Bish <[email protected]> Committed: Tue Apr 21 15:58:06 2015 -0400 ---------------------------------------------------------------------- .../apache/activemq/transport/amqp/protocol/AmqpReceiver.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/ff1a1c49/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java ---------------------------------------------------------------------- diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java index 56ce1e7..5630d6c 100644 --- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java +++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java @@ -141,11 +141,11 @@ public class AmqpReceiver extends AmqpAbstractReceiver { protected InboundTransformer getInboundTransformer() { if (inboundTransformer == null) { String transformer = session.getConnection().getConfiguredTransformer(); - if (transformer.equals(InboundTransformer.TRANSFORMER_JMS)) { + if (transformer.equalsIgnoreCase(InboundTransformer.TRANSFORMER_JMS)) { inboundTransformer = new JMSMappingInboundTransformer(ActiveMQJMSVendor.INSTANCE); - } else if (transformer.equals(InboundTransformer.TRANSFORMER_NATIVE)) { + } else if (transformer.equalsIgnoreCase(InboundTransformer.TRANSFORMER_NATIVE)) { inboundTransformer = new AMQPNativeInboundTransformer(ActiveMQJMSVendor.INSTANCE); - } else if (transformer.equals(InboundTransformer.TRANSFORMER_RAW)) { + } else if (transformer.equalsIgnoreCase(InboundTransformer.TRANSFORMER_RAW)) { inboundTransformer = new AMQPRawInboundTransformer(ActiveMQJMSVendor.INSTANCE); } else { LOG.warn("Unknown transformer type {} using native one instead", transformer);
