You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2015/04/21 21:58:28 UTC
activemq git commit: https://issues.apache.org/jira/browse/AMQ-5737
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 <ta...@gmail.com>
Authored: Tue Apr 21 15:58:06 2015 -0400
Committer: Timothy Bish <ta...@gmail.com>
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);