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.


---

Reply via email to