You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by lq...@apache.org on 2017/09/28 13:36:09 UTC
[12/12] qpid-broker-j git commit: QPID-7531: [Java Broker,
AMQP 1.0] Fix detection of GZIP compression in Message Conversion for
AMQP 1.0
QPID-7531: [Java Broker, AMQP 1.0] Fix detection of GZIP compression in Message Conversion for AMQP 1.0
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/2632d13e
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/2632d13e
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/2632d13e
Branch: refs/heads/master
Commit: 2632d13e9888facfa619c75c754801ea1556ec23
Parents: 6a26717
Author: Lorenz Quack <lq...@apache.org>
Authored: Mon Sep 25 11:16:24 2017 +0100
Committer: Lorenz Quack <lq...@apache.org>
Committed: Thu Sep 28 14:30:17 2017 +0100
----------------------------------------------------------------------
.../apache/qpid/server/protocol/v1_0/MessageConverter_to_1_0.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/2632d13e/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/MessageConverter_to_1_0.java
----------------------------------------------------------------------
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/MessageConverter_to_1_0.java b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/MessageConverter_to_1_0.java
index 6d4b653..eab7093 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/MessageConverter_to_1_0.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/MessageConverter_to_1_0.java
@@ -366,7 +366,7 @@ public abstract class MessageConverter_to_1_0<M extends ServerMessage> implement
}
byte[] uncompressed;
- if(Symbol.valueOf(GZIPUtils.GZIP_CONTENT_ENCODING).equals(serverMessage.getMessageHeader().getEncoding())
+ if(GZIPUtils.GZIP_CONTENT_ENCODING.equals(serverMessage.getMessageHeader().getEncoding())
&& (uncompressed = GZIPUtils.uncompressBufferToArray(ByteBuffer.wrap(data))) != null)
{
data = uncompressed;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org