Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/1853#discussion_r166179369 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/PageSubscription.java --- @@ -161,4 +165,9 @@ * @throws Exception */ void onDeletePage(Page deletedPage) throws Exception; + + AtomicLong getDeliveredCount(); --- End diff -- not sure would want to expose an atomic outside the object as it allows other code to update it unexpectedly, should probably be primitive and the object should return get on the atomic.
---