ARTEMIS-1105 Adding setPaged that was missed during the refactoring
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/4a73d829 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/4a73d829 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/4a73d829 Branch: refs/heads/master Commit: 4a73d8296451f2e1031cdaa84d1ba15feebcacf3 Parents: 185b0cb Author: Clebert Suconic <[email protected]> Authored: Mon Apr 10 12:25:07 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Mon Apr 10 12:25:28 2017 -0400 ---------------------------------------------------------------------- .../apache/activemq/artemis/core/paging/impl/PagedMessageImpl.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/4a73d829/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagedMessageImpl.java ---------------------------------------------------------------------- diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagedMessageImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagedMessageImpl.java index 0b207ec..d7bd05c 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagedMessageImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagedMessageImpl.java @@ -75,6 +75,7 @@ public class PagedMessageImpl implements PagedMessage { ActiveMQBuffer buffer = ActiveMQBuffers.wrappedBuffer(largeMessageLazyData); lgMessage = LargeMessagePersister.getInstance().decode(buffer, lgMessage); lgMessage.incrementDelayDeletionCount(); + lgMessage.setPaged(); this.message = lgMessage; largeMessageLazyData = null; }
