activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [3/4] activemq-artemis git commit: ARTEMIS-1041 Adjusting when hearders are being parsed
Date Wed, 15 Mar 2017 23:31:06 GMT
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 <clebertsuconic@apache.org>
Authored: Wed Mar 15 19:22:42 2017 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
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();
    }
 }


Mime
View raw message