Skip to content

Commit ff27f2a

Browse files
committed
Reduce number of threads in tests
References #87
1 parent a3abbd8 commit ff27f2a

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/test/java/com/rabbitmq/perf/MessageCountTimeLimitAndPublishingIntervalRateTest.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -99,18 +99,18 @@ protected void report(long now) {
9999
static Stream<Arguments> producerCountArguments() {
100100
return Stream.of(
101101
Arguments.of(1, 1),
102-
Arguments.of(10, 1),
103-
Arguments.of(1, 10),
104-
Arguments.of(2, 5)
102+
Arguments.of(3, 1),
103+
Arguments.of(1, 3),
104+
Arguments.of(2, 3)
105105
);
106106
}
107107

108108
static Stream<Arguments> consumerCountArguments() {
109109
return Stream.of(
110110
Arguments.of(1, 1),
111-
Arguments.of(10, 1),
112-
Arguments.of(1, 10),
113-
Arguments.of(2, 5)
111+
Arguments.of(3, 1),
112+
Arguments.of(1, 3),
113+
Arguments.of(2, 3)
114114
);
115115
}
116116

@@ -195,7 +195,7 @@ public void timeLimit() {
195195
@ParameterizedTest
196196
@MethodSource("producerCountArguments")
197197
public void producerCount(int producersCount, int channelsCount) throws Exception {
198-
int messagesCount = 10;
198+
int messagesCount = producersCount * channelsCount;
199199
countsAndTimeLimit(messagesCount, 0, 0);
200200
params.setProducerCount(producersCount);
201201
params.setProducerChannelCount(channelsCount);
@@ -228,7 +228,7 @@ public void producerCount(int producersCount, int channelsCount) throws Exceptio
228228
@ParameterizedTest
229229
@MethodSource("consumerCountArguments")
230230
public void consumerCount(int consumersCount, int channelsCount) throws Exception {
231-
int messagesCount = 10;
231+
int messagesCount = consumersCount * channelsCount;
232232
countsAndTimeLimit(0, messagesCount, 0);
233233
params.setConsumerCount(consumersCount);
234234
params.setConsumerChannelCount(channelsCount);

0 commit comments

Comments
 (0)