Skip to content

Commit fb227d5

Browse files
committed
Stabilize NATS priority queue E2E test
1 parent 3839668 commit fb227d5

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/NatsPriorityQueuesE2EIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ static class PriorityListener {
9191
final CountDownLatch latch = new CountDownLatch(10);
9292
final List<String> received = Collections.synchronizedList(new ArrayList<>());
9393

94-
@RqueueListener(value = "pq", priority = "high=10,low=1")
94+
@RqueueListener(value = "pq", priority = "high=10,low=1", batchSize = "5", concurrency = "5")
9595
void onMessage(String payload) {
9696
received.add(payload);
9797
latch.countDown();

0 commit comments

Comments
 (0)