Test

Author: zguesmi

src/main/java/com/iexec/worker/pubsub/StompClient.java

@@ -102,7 +102,7 @@ private void requestNewSession() {
      * @throws InterruptedException
      */
     @Scheduled(fixedDelay = 1000)
-    private void listenToSessionRequestEvents() throws InterruptedException {
+    private void listenToSessionRequestEventsInTheQueue() throws InterruptedException {
         while (true) {
             // get the first request event or wait until available
             this.sessionRequestQueue.take();

src/test/java/com/iexec/worker/pubsub/StompClientTests.java

@@ -0,0 +1,16 @@
+package com.iexec.worker.pubsub;
+
+import org.junit.Before;
+import org.mockito.InjectMocks;
+import org.mockito.MockitoAnnotations;
+
+public class StompClientTests {
+
+    @InjectMocks
+    private StompClient stompClient;
+
+    @Before
+    public void init() {
+        MockitoAnnotations.initMocks(this);
+    }
+}