Repository: activemq-artemis Updated Branches: refs/heads/master f9dd891db -> 696206b1d
fixing log.trace Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/17ffcd48 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/17ffcd48 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/17ffcd48 Branch: refs/heads/master Commit: 17ffcd48c23be1fdb889599bee584f6a715991a8 Parents: f9dd891 Author: Clebert Suconic <[email protected]> Authored: Wed Jun 8 14:15:13 2016 -0400 Committer: Clebert Suconic <[email protected]> Committed: Wed Jun 8 21:41:57 2016 -0400 ---------------------------------------------------------------------- .../artemis/core/paging/cursor/impl/PageSubscriptionImpl.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/17ffcd48/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java ---------------------------------------------------------------------- diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java index 80ed67e..9eac4ce 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java @@ -592,8 +592,11 @@ final class PageSubscriptionImpl implements PageSubscription { return true; } else { - logger.tracef("isComplete(%d)::calling is %s", (Object)page, this, consumedPages.isEmpty()); - return info != null && info.isDone(); + boolean isDone = info != null && info.isDone(); + if (logger.isTraceEnabled()) { + logger.tracef("isComplete(%d):: found info=%s, isDone=%s", (Object) page, info, isDone); + } + return isDone; } } }
