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
The following commit(s) were added to refs/heads/master by this push:
new ba2f5ddc6f JAMES-3747 Fixup RabbitMQEventBusTest
ba2f5ddc6f is described below
commit ba2f5ddc6f66eedc572478287482d388c6cb4da4
Author: Tung Tran <[email protected]>
AuthorDate: Thu Jul 25 18:56:28 2024 +0700
JAMES-3747 Fixup RabbitMQEventBusTest
- `eventBus.register(listener, KEY_1)` is a publisher, we need to subscribe
it
- resolve deprecated method
---
.../apache/james/events/RabbitMQEventBusTest.java | 21 +++++++++++----------
1 file changed, 11 insertions(+), 10 deletions(-)
diff --git
a/event-bus/distributed/src/test/java/org/apache/james/events/RabbitMQEventBusTest.java
b/event-bus/distributed/src/test/java/org/apache/james/events/RabbitMQEventBusTest.java
index d0a093036b..d2593e9602 100644
---
a/event-bus/distributed/src/test/java/org/apache/james/events/RabbitMQEventBusTest.java
+++
b/event-bus/distributed/src/test/java/org/apache/james/events/RabbitMQEventBusTest.java
@@ -452,7 +452,7 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
class DispatchingWhenNetWorkIssue {
@RegisterExtension
- RabbitMQExtension rabbitMQNetWorkIssueExtension =
RabbitMQExtension.defaultRabbitMQ()
+ static RabbitMQExtension rabbitMQNetWorkIssueExtension =
RabbitMQExtension.defaultRabbitMQ()
.restartPolicy(DockerRestartPolicy.PER_TEST)
.isolationPolicy(RabbitMQExtension.IsolationPolicy.WEAK);
@@ -472,7 +472,7 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
rabbitMQNetWorkIssueExtension.getRabbitMQ().pause();
assertThatThrownBy(() ->
rabbitMQEventBusWithNetWorkIssue.dispatch(EVENT, NO_KEYS).block())
- .getCause()
+ .cause()
.isInstanceOf(NoSuchElementException.class)
.hasMessageContaining("Timeout waiting for idle
object");
@@ -488,7 +488,8 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
eventBus.start();
assertThat(rabbitManagementAPI.listExchanges())
.filteredOn(exchange ->
exchange.getName().equals(TEST_NAMING_STRATEGY.exchange()))
- .hasOnlyOneElementSatisfying(exchange -> {
+ .singleElement()
+ .satisfies(exchange -> {
assertThat(exchange.isDurable()).isTrue();
assertThat(exchange.getType()).isEqualTo(DIRECT_EXCHANGE);
});
@@ -595,7 +596,7 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
rabbitMQExtension.getRabbitMQ().pause();
assertThatThrownBy(() -> eventBus.dispatch(EVENT,
NO_KEYS).block())
- .getCause()
+ .cause()
.isInstanceOf(NoSuchElementException.class)
.hasMessageContaining("Timeout waiting for idle
object");
@@ -633,7 +634,7 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
rabbitMQExtension.getRabbitMQ().pause();
assertThatThrownBy(() -> eventBus.dispatch(EVENT,
NO_KEYS).block())
- .getCause()
+ .cause()
.isInstanceOf(NoSuchElementException.class)
.hasMessageContaining("Timeout waiting for idle
object");
@@ -652,7 +653,7 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
rabbitMQExtension.getRabbitMQ().pause();
assertThatThrownBy(() -> eventBus.dispatch(EVENT,
NO_KEYS).block())
- .getCause()
+ .cause()
.isInstanceOf(NoSuchElementException.class)
.hasMessageContaining("Timeout waiting for idle
object");
@@ -703,7 +704,7 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
EventListenerCountingSuccessfulExecution listener = new
EventListenerCountingSuccessfulExecution();
eventBus.register(listener, GROUP_A);
- try (Closeable closeable = ConcurrentTestRunner.builder()
+ try (Closeable ignored = ConcurrentTestRunner.builder()
.operation((threadNumber, step) ->
eventBus.dispatch(EVENT, KEY_1).block())
.threadCount(THREAD_COUNT)
.operationCount(OPERATION_COUNT)
@@ -800,7 +801,7 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
eventBus.register(listener, GROUP_A);
eventBus2.register(listener, GROUP_A);
- try (Closeable closeable = ConcurrentTestRunner.builder()
+ try (Closeable ignored = ConcurrentTestRunner.builder()
.operation((threadNumber, step) ->
eventBus.dispatch(EVENT, KEY_1).block())
.threadCount(THREAD_COUNT)
.operationCount(OPERATION_COUNT)
@@ -857,8 +858,8 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
void eventBusPubSubWithDistinctNamingStrategiesShouldBeIsolated()
throws Exception {
EventCollector listener = new EventCollector();
EventCollector otherListener = new EventCollector();
- eventBus.register(listener, KEY_1);
- otherEventBus.register(otherListener, KEY_1);
+ Mono.from(eventBus.register(listener, KEY_1)).block();
+ Mono.from(otherEventBus.register(otherListener, KEY_1)).block();
eventBus.dispatch(EVENT, ImmutableSet.of(KEY_1)).block();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
