This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 350dd3cf212b174edbe4c86f6fca9f7a9dd4d2f6
Author: Matthieu Baechler <matth...@apache.org>
AuthorDate: Thu Jan 9 14:29:20 2020 +0100
JAMES-3025 refactor LocalListenerRegistryTest to use
randomlyDistributedOperations
---
.../mailbox/events/LocalListenerRegistryTest.java | 25 +++++++++-------------
1 file changed, 10 insertions(+), 15 deletions(-)
diff --git
a/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/LocalListenerRegistryTest.java
b/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/LocalListenerRegistryTest.java
index 8136239..0726f1a 100644
---
a/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/LocalListenerRegistryTest.java
+++
b/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/LocalListenerRegistryTest.java
@@ -146,15 +146,10 @@ class LocalListenerRegistryTest {
MailboxListener listener3 = event -> { };
ConcurrentTestRunner.builder()
- .operation((threadNumber, operationNumber) -> {
- if (threadNumber % 3 == 0) {
- testee.addListener(KEY_1, listener1);
- } else if (threadNumber % 3 == 1) {
- testee.addListener(KEY_1, listener2);
- } else if (threadNumber % 3 == 2) {
- testee.addListener(KEY_1, listener3);
- }
- })
+ .randomlyDistributedOperations(
+ (threadNumber, operationNumber) ->
testee.addListener(KEY_1, listener1),
+ (threadNumber, operationNumber) ->
testee.addListener(KEY_1, listener2),
+ (threadNumber, operationNumber) ->
testee.addListener(KEY_1, listener3))
.threadCount(6)
.operationCount(10)
.runSuccessfullyWithin(ONE_SECOND);
@@ -188,24 +183,24 @@ class LocalListenerRegistryTest {
AtomicInteger firstListenerCount = new AtomicInteger(0);
ConcurrentTestRunner.builder()
- .operation((threadNumber, operationNumber) -> {
- if (threadNumber % 3 == 0) {
+ .randomlyDistributedOperations((threadNumber, operationNumber)
-> {
LocalListenerRegistry.LocalRegistration registration =
testee.addListener(KEY_1, listener1);
if (registration.isFirstListener()) {
firstListenerCount.incrementAndGet();
}
- } else if (threadNumber % 3 == 1) {
+ },
+ (threadNumber, operationNumber) -> {
LocalListenerRegistry.LocalRegistration registration =
testee.addListener(KEY_1, listener2);
if (registration.isFirstListener()) {
firstListenerCount.incrementAndGet();
}
- } else if (threadNumber % 3 == 2) {
+ },
+ (threadNumber, operationNumber) -> {
LocalListenerRegistry.LocalRegistration registration =
testee.addListener(KEY_1, listener3);
if (registration.isFirstListener()) {
firstListenerCount.incrementAndGet();
}
- }
- })
+ })
.threadCount(6)
.operationCount(10)
.runSuccessfullyWithin(ONE_SECOND);
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org
