Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-5159 lowering number of threads on SoakReplicatedPagingTest

This commit is contained in:
Clebert Suconic 2024-11-14 21:41:23 -05:00 committed by clebertsuconic
parent 717808ce3f
commit f3341a5337
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java
View File

@ -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);