Loading src/test/java/es/redmic/test/tasks/integration/report/common/ReportBaseTest.java +2 −2 Original line number Diff line number Diff line Loading @@ -53,7 +53,7 @@ public abstract class ReportBaseTest extends IntegrationTestBase { sender.send(getRunTopic(), payload); // Recibe tarea registrada MessageWrapper msg = (MessageWrapper) blockingQueue.poll(10, TimeUnit.SECONDS); MessageWrapper msg = (MessageWrapper) blockingQueue.poll(50, TimeUnit.SECONDS); assertNotNull(msg); taskId = msg.getActionId(); assertEquals(msg.getUserId(), USER_ID); Loading @@ -67,7 +67,7 @@ public abstract class ReportBaseTest extends IntegrationTestBase { assertEquals(registeredTaskDTO.getStatus().toString(), TaskStatus.Constants.REGISTERED); // Recibe tarea arrancada msg = (MessageWrapper) blockingQueue.poll(10, TimeUnit.SECONDS); msg = (MessageWrapper) blockingQueue.poll(50, TimeUnit.SECONDS); assertNotNull(msg); assertEquals(msg.getUserId(), USER_ID); Loading Loading
src/test/java/es/redmic/test/tasks/integration/report/common/ReportBaseTest.java +2 −2 Original line number Diff line number Diff line Loading @@ -53,7 +53,7 @@ public abstract class ReportBaseTest extends IntegrationTestBase { sender.send(getRunTopic(), payload); // Recibe tarea registrada MessageWrapper msg = (MessageWrapper) blockingQueue.poll(10, TimeUnit.SECONDS); MessageWrapper msg = (MessageWrapper) blockingQueue.poll(50, TimeUnit.SECONDS); assertNotNull(msg); taskId = msg.getActionId(); assertEquals(msg.getUserId(), USER_ID); Loading @@ -67,7 +67,7 @@ public abstract class ReportBaseTest extends IntegrationTestBase { assertEquals(registeredTaskDTO.getStatus().toString(), TaskStatus.Constants.REGISTERED); // Recibe tarea arrancada msg = (MessageWrapper) blockingQueue.poll(10, TimeUnit.SECONDS); msg = (MessageWrapper) blockingQueue.poll(50, TimeUnit.SECONDS); assertNotNull(msg); assertEquals(msg.getUserId(), USER_ID); Loading