ARTEMIS-332 Fixing possible NPE on Paging
This commit is contained in:
parent
74245a58bd
commit
b82808797e
|
@ -1271,9 +1271,9 @@ final class PageSubscriptionImpl implements PageSubscription {
|
|||
deliveredCount.incrementAndGet();
|
||||
PagedReference delivery = currentDelivery;
|
||||
if (delivery != null) {
|
||||
PageCursorInfo info = PageSubscriptionImpl.this.getPageInfo(currentDelivery.getPosition());
|
||||
PageCursorInfo info = PageSubscriptionImpl.this.getPageInfo(delivery.getPosition());
|
||||
if (info != null) {
|
||||
info.remove(currentDelivery.getPosition());
|
||||
info.remove(delivery.getPosition());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue