Repository: activemq-artemis Updated Branches: refs/heads/master ae738c426 -> f5a73dfab
ARTEMIS-2096 Fixing DivertTopicToQueueTest This is fixing the test org.apache.activemq.artemis.tests.integration.amqp.DivertTopicToQueueTest This test was broken because the copy wouldn't use the Buffer view gotten by data.duplicate(). Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/48b55632 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/48b55632 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/48b55632 Branch: refs/heads/master Commit: 48b5563241a28563a72d83431790b2f6b45b1582 Parents: ae738c4 Author: Clebert Suconic <[email protected]> Authored: Wed Oct 10 12:09:40 2018 -0400 Committer: Timothy Bish <[email protected]> Committed: Wed Oct 10 12:27:45 2018 -0400 ---------------------------------------------------------------------- .../apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/48b55632/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 821356a..c7f1b50 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 @@ -497,7 +497,7 @@ public class AMQPMessage extends RefCountMessage { // Copy the full message contents with delivery annotations as they will // be trimmed on send and may become useful on the broker at a later time. - data.get(newData); + view.get(newData); AMQPMessage newEncode = new AMQPMessage(this.messageFormat, newData, extraProperties, coreMessageObjectPools); newEncode.setMessageID(this.getMessageID());
