ARTEMIS-1041 Adjusting when hearders are being parsed
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/31639782 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/31639782 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/31639782 Branch: refs/heads/master Commit: 31639782f0ddb31ee32d2d9955420d7ccd183d32 Parents: 8a84b6a Author: Clebert Suconic <[email protected]> Authored: Wed Mar 15 19:22:42 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Wed Mar 15 19:27:59 2017 -0400 ---------------------------------------------------------------------- .../apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/31639782/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java ---------------------------------------------------------------------- diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java index 56ac1f5..60aae4c 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java @@ -80,6 +80,7 @@ public class AMQPMessage extends RefCountMessage { this.data = Unpooled.wrappedBuffer(data); this.messageFormat = messageFormat; this.bufferValid = true; + parseHeaders(); } @@ -897,5 +898,6 @@ public class AMQPMessage extends RefCountMessage { record.readBytes(recordArray); this.data = Unpooled.wrappedBuffer(recordArray); this.bufferValid = true; + parseHeaders(); } }
