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 f3341a5337 ARTEMIS-5159 lowering number of threads on
SoakReplicatedPagingTest
f3341a5337 is described below
commit f3341a5337bcdf9a22563c59e682d58fcd464cbc
Author: Clebert Suconic <[email protected]>
AuthorDate: Thu Nov 14 21:41:23 2024 -0500
ARTEMIS-5159 lowering number of threads on SoakReplicatedPagingTest
---
.../tests/soak/replicationflow/SoakReplicatedPagingTest.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java
b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java
index b0bb6daefa..84c60f581d 100644
---
a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java
+++
b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java
@@ -147,8 +147,8 @@ public class SoakReplicatedPagingTest extends SoakTestBase {
server0 = startServer(SERVER_NAME_0, 0, 30000);
}
- static final int consumer_threads = 20;
- static final int producer_threads = 20;
+ static final int CONSUMER_THREADS = 5;
+ static final int PRODUCER_THREADS = 5;
static AtomicInteger producer_count = new AtomicInteger(0);
static AtomicInteger consumer_count = new AtomicInteger(0);
@@ -187,10 +187,10 @@ public class SoakReplicatedPagingTest extends
SoakTestBase {
final ConnectionFactory factory = createConnectionFactory(protocol,
"tcp://" + host + ":" + port);
- CountDownLatch producersLatch = new CountDownLatch(producer_threads);
- CountDownLatch consumersLatch = new CountDownLatch(consumer_threads);
+ CountDownLatch producersLatch = new CountDownLatch(PRODUCER_THREADS);
+ CountDownLatch consumersLatch = new CountDownLatch(CONSUMER_THREADS);
- for (int i = 0; i < producer_threads; i++) {
+ for (int i = 0; i < PRODUCER_THREADS; i++) {
Thread t = new Thread(() -> {
SoakReplicatedPagingTest app = new
SoakReplicatedPagingTest(protocol, consumerType, tx);
app.produce(factory, producer_count.incrementAndGet(),
producersLatch);
@@ -200,7 +200,7 @@ public class SoakReplicatedPagingTest extends SoakTestBase {
Thread.sleep(1000);
- for (int i = 0; i < consumer_threads; i++) {
+ for (int i = 0; i < CONSUMER_THREADS; i++) {
Thread t = new Thread(() -> {
SoakReplicatedPagingTest app = new
SoakReplicatedPagingTest(protocol, consumerType, tx);
app.consume(factory, consumer_count.getAndIncrement(),
consumersLatch);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
