Loading src/test/java/es/redmic/test/tasks/integration/ingest/common/IngestBaseTest.java +3 −3 Original line number Diff line number Diff line Loading @@ -61,7 +61,7 @@ public abstract class IngestBaseTest extends IntegrationTestBase { sender.send(getRunTopic(), payload); // Recibe tarea registrada MessageWrapper msg = (MessageWrapper) blockingQueue.poll(10, TimeUnit.SECONDS); MessageWrapper msg = (MessageWrapper) blockingQueue.poll(30, TimeUnit.SECONDS); assertNotNull(msg); taskId = msg.getActionId(); assertEquals(msg.getUserId(), USER_ID); Loading @@ -75,7 +75,7 @@ public abstract class IngestBaseTest extends IntegrationTestBase { assertEquals(registeredTaskDTO.getStatus().toString(), TaskStatus.Constants.REGISTERED); // Recibe tarea arrancada msg = (MessageWrapper) blockingQueue.poll(10, TimeUnit.SECONDS); msg = (MessageWrapper) blockingQueue.poll(30, TimeUnit.SECONDS); assertNotNull(msg); assertEquals(msg.getUserId(), USER_ID); Loading @@ -86,7 +86,7 @@ public abstract class IngestBaseTest extends IntegrationTestBase { assertEquals(startedTaskDTO.getStatus().toString(), TaskStatus.Constants.STARTED); // Recibe petición de matching msg = (MessageWrapper) blockingQueue.poll(20, TimeUnit.SECONDS); msg = (MessageWrapper) blockingQueue.poll(30, TimeUnit.SECONDS); assertNotNull(msg); assertEquals(msg.getUserId(), USER_ID); Loading src/test/java/es/redmic/test/tasks/integration/report/common/ReportBaseTest.java +1 −1 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(50, TimeUnit.SECONDS); MessageWrapper msg = (MessageWrapper) blockingQueue.poll(60, TimeUnit.SECONDS); assertNotNull(msg); taskId = msg.getActionId(); assertEquals(msg.getUserId(), USER_ID); Loading Loading
src/test/java/es/redmic/test/tasks/integration/ingest/common/IngestBaseTest.java +3 −3 Original line number Diff line number Diff line Loading @@ -61,7 +61,7 @@ public abstract class IngestBaseTest extends IntegrationTestBase { sender.send(getRunTopic(), payload); // Recibe tarea registrada MessageWrapper msg = (MessageWrapper) blockingQueue.poll(10, TimeUnit.SECONDS); MessageWrapper msg = (MessageWrapper) blockingQueue.poll(30, TimeUnit.SECONDS); assertNotNull(msg); taskId = msg.getActionId(); assertEquals(msg.getUserId(), USER_ID); Loading @@ -75,7 +75,7 @@ public abstract class IngestBaseTest extends IntegrationTestBase { assertEquals(registeredTaskDTO.getStatus().toString(), TaskStatus.Constants.REGISTERED); // Recibe tarea arrancada msg = (MessageWrapper) blockingQueue.poll(10, TimeUnit.SECONDS); msg = (MessageWrapper) blockingQueue.poll(30, TimeUnit.SECONDS); assertNotNull(msg); assertEquals(msg.getUserId(), USER_ID); Loading @@ -86,7 +86,7 @@ public abstract class IngestBaseTest extends IntegrationTestBase { assertEquals(startedTaskDTO.getStatus().toString(), TaskStatus.Constants.STARTED); // Recibe petición de matching msg = (MessageWrapper) blockingQueue.poll(20, TimeUnit.SECONDS); msg = (MessageWrapper) blockingQueue.poll(30, TimeUnit.SECONDS); assertNotNull(msg); assertEquals(msg.getUserId(), USER_ID); Loading
src/test/java/es/redmic/test/tasks/integration/report/common/ReportBaseTest.java +1 −1 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(50, TimeUnit.SECONDS); MessageWrapper msg = (MessageWrapper) blockingQueue.poll(60, TimeUnit.SECONDS); assertNotNull(msg); taskId = msg.getActionId(); assertEquals(msg.getUserId(), USER_ID); Loading