fix(datashare-tasks): fix flaky AmqpTest

Author: ClemDoum

datashare-tasks/src/test/java/org/icij/datashare/asynctasks/bus/amqp/AmqpTest.java

@@ -5,8 +5,8 @@
 import java.util.Optional;
 import org.icij.datashare.asynctasks.NackException;
 import org.icij.datashare.json.JsonObjectMapper;
-import org.junit.After;
 import org.junit.AfterClass;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.ClassRule;
 import org.junit.Ignore;
@@ -33,11 +33,16 @@ public class AmqpTest {
     static private AmqpInterlocutor amqp;
 
     @BeforeClass
-    public static void setUp() throws Exception {
+    public static void setUpClass() throws Exception {
         AmqpQueue[] queues = {AmqpQueue.EVENT, AmqpQueue.MANAGER_EVENT};
         amqp = new AmqpInterlocutor(new Configuration(new URI("amqp://admin:admin@localhost:12345?nbMessageMax=10&rabbitMq=false")), queues);
     }
 
+    @Before
+    public void setUp() throws Exception {
+        eventQueue.clear();
+    }
+
     @Test
     public void test_publish_receive() throws Exception {
         AmqpConsumer<TestEvent, TestEventConsumer> consumer = new AmqpConsumer<>(amqp, new TestEventConsumer(), AmqpQueue.EVENT, TestEvent.class);
@@ -172,11 +177,6 @@ public void test_routing_with_suffix() throws Exception {
         consumer.cancel();
     }
 
-    @After
-    public void tearDown() throws Exception {
-        eventQueue.clear();
-    }
-
     @AfterClass
     public static void afterClass() throws Exception {
         amqp.close();