Github user cshannon commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1853#discussion_r166271561
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
---
@@ -374,8 +403,43 @@ private ItemOper(PageSubscriptionCounterImpl counter,
long id, int add) {
@Override
public void afterCommit(Transaction tx) {
for (ItemOper oper : operations) {
- oper.counter.incrementProcessed(oper.id, oper.amount);
+ oper.counter.incrementProcessed(oper.id, oper.amount,
oper.size);
}
}
}
+
+ private static class PendingCounter {
+ final long id;
+ final AtomicInteger count;
--- End diff --
What do you mean by atomic updater, do you mean using something like
AtomicIntegerFieldUpdater ?
---
