This is an automated email from the ASF dual-hosted git repository.
brusdev pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 9b574af341 ARTEMIS-4967 Remove unreachable code
9b574af341 is described below
commit 9b574af34154e6650ff258c726d6ebcaf7351537
Author: Timothy Bish <[email protected]>
AuthorDate: Wed May 28 16:28:07 2025 -0400
ARTEMIS-4967 Remove unreachable code
Remove code that has been unreachable since original donation
so should not have any side effect at this point.
---
.../artemis/core/paging/cursor/impl/PageSubscriptionImpl.java | 6 ------
1 file changed, 6 deletions(-)
diff --git
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
index 745a7da608..386e7bbbdc 100644
---
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
+++
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
@@ -687,8 +687,6 @@ public final class PageSubscriptionImpl implements
PageSubscription {
Collections.sort(recoveredACK);
- long txDeleteCursorOnReload = -1;
-
for (PagePosition pos : recoveredACK) {
logger.trace("reloading pos {}", pos);
lastAckedPosition = pos;
@@ -696,10 +694,6 @@ public final class PageSubscriptionImpl implements
PageSubscription {
pageInfo.loadACK(pos);
}
- if (txDeleteCursorOnReload >= 0) {
- store.commit(txDeleteCursorOnReload);
- }
-
recoveredACK.clear();
recoveredACK = null;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
