This is an automated email from the ASF dual-hosted git repository.
clebertsuconic 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 09911e9977 NO-JIRA Removing dead code from test
09911e9977 is described below
commit 09911e997751f4278aae383fb6e817dbd49697e5
Author: Clebert Suconic <[email protected]>
AuthorDate: Wed Apr 23 17:22:21 2025 -0400
NO-JIRA Removing dead code from test
---
.../tests/unit/core/paging/impl/PageTimedWriterUnitTest.java | 6 ------
1 file changed, 6 deletions(-)
diff --git
a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PageTimedWriterUnitTest.java
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PageTimedWriterUnitTest.java
index 3fc0fc3208..7e58d160d4 100644
---
a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PageTimedWriterUnitTest.java
+++
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/paging/impl/PageTimedWriterUnitTest.java
@@ -926,8 +926,6 @@ public class PageTimedWriterUnitTest extends
ArtemisTestCase {
@Test
public void testLockWhileFlowControlled() throws Exception {
- AtomicBoolean notSupposedToWrite = new AtomicBoolean(false);
-
AtomicInteger errors = new AtomicInteger(0);
LinkedHashSet<String> interceptedWrite = new LinkedHashSet<>();
@@ -939,10 +937,6 @@ public class PageTimedWriterUnitTest extends
ArtemisTestCase {
logger.warn("no messageID defined on message");
errors.incrementAndGet();
}
- if (notSupposedToWrite.get()) {
- logger.warn("Not supposed to write message {}",
m.getMessage().getStringProperty("testId"));
- errors.incrementAndGet();
- }
interceptedWrite.add(m.getMessage().getStringProperty("testId"));
};
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
