This closes #569
This commit is contained in:
commit
3d3a8fada0
|
@ -580,7 +580,7 @@ final class PageSubscriptionImpl implements PageSubscription {
|
||||||
synchronized (consumedPages) {
|
synchronized (consumedPages) {
|
||||||
if (empty && consumedPages.isEmpty()) {
|
if (empty && consumedPages.isEmpty()) {
|
||||||
if (logger.isTraceEnabled()) {
|
if (logger.isTraceEnabled()) {
|
||||||
logger.tracef("isComplete(%d)::Subscription %s has empty=%s, consumedPages.isEmpty=%s", (Object)page, this, consumedPages.isEmpty());
|
logger.tracef("isComplete(%d)::Subscription %s has empty=%s, consumedPages.isEmpty=%s", page, this, empty, consumedPages.isEmpty());
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue