You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/05/21 03:14:38 UTC
[james-project] 06/06: JAMES-2774 Restart docker RabbitMQ each
tests in RabbitMQEventBusTest
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 5dc293c14b5d07643a9f6a786793319b2a9cef42
Author: Tran Tien Duc <dt...@linagora.com>
AuthorDate: Mon May 20 16:55:01 2019 +0700
JAMES-2774 Restart docker RabbitMQ each tests in RabbitMQEventBusTest
---
.../james/mailbox/events/RabbitMQEventBusTest.java | 19 ++++++++++++++++++-
1 file changed, 18 insertions(+), 1 deletion(-)
diff --git a/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java b/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java
index 83eccba..e0c7a72 100644
--- a/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java
+++ b/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java
@@ -66,10 +66,12 @@ import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtensionContext;
import org.junit.jupiter.api.extension.RegisterExtension;
import org.mockito.stubbing.Answer;
import com.rabbitmq.client.Connection;
+
import reactor.core.publisher.Mono;
import reactor.rabbitmq.BindingSpecification;
import reactor.rabbitmq.ExchangeSpecification;
@@ -85,8 +87,23 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract,
KeyContract.SingleEventBusKeyContract, KeyContract.MultipleEventBusKeyContract,
ErrorHandlingContract {
+ static class RestartingRabbitMQExtension extends RabbitMQExtension {
+
+ @Override
+ public void beforeEach(ExtensionContext extensionContext) throws Exception {
+ getRabbitMQ().start();
+ super.beforeEach(extensionContext);
+ }
+
+ @Override
+ public void afterEach(ExtensionContext context) {
+ super.afterEach(context);
+ getRabbitMQ().stop();
+ }
+ }
+
@RegisterExtension
- static RabbitMQExtension rabbitMQExtension = new RabbitMQExtension();
+ static RestartingRabbitMQExtension rabbitMQExtension = new RestartingRabbitMQExtension();
private RabbitMQEventBus eventBus;
private RabbitMQEventBus eventBus2;
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org