Loading atlas-commands/src/test/java/es/redmic/test/atlascommands/integration/category/CategoryCommandHandlerTest.java +3 −1 Original line number Diff line number Diff line Loading @@ -330,7 +330,9 @@ public class CategoryCommandHandlerTest extends KafkaBaseIntegrationTest { // Envía created para meterlo en el stream y lo saca de la cola CategoryCreatedEvent categoryCreatedEvent = CategoryDataUtil.getCategoryCreatedEvent(code + "7"); kafkaTemplate.send(category_topic, categoryCreatedEvent.getAggregateId(), categoryCreatedEvent); blockingQueue.poll(10, TimeUnit.SECONDS); blockingQueue.poll(30, TimeUnit.SECONDS); Thread.sleep(8000); PrepareRollbackEvent event = CategoryDataUtil.getPrepareRollbackEvent(code + "7"); Loading atlas-commands/src/test/java/es/redmic/test/atlascommands/integration/themeinspire/ThemeInspireCommandHandlerTest.java +3 −1 Original line number Diff line number Diff line Loading @@ -376,7 +376,9 @@ public class ThemeInspireCommandHandlerTest extends KafkaBaseIntegrationTest { ThemeInspireCreatedEvent themeInspireCreatedEvent = ThemeInspireDataUtil .getThemeInspireCreatedEvent(code + "7"); kafkaTemplate.send(theme_inspire_topic, themeInspireCreatedEvent.getAggregateId(), themeInspireCreatedEvent); blockingQueue.poll(10, TimeUnit.SECONDS); blockingQueue.poll(30, TimeUnit.SECONDS); Thread.sleep(8000); PrepareRollbackEvent event = ThemeInspireDataUtil.getPrepareRollbackEvent(code + "7"); Loading Loading
atlas-commands/src/test/java/es/redmic/test/atlascommands/integration/category/CategoryCommandHandlerTest.java +3 −1 Original line number Diff line number Diff line Loading @@ -330,7 +330,9 @@ public class CategoryCommandHandlerTest extends KafkaBaseIntegrationTest { // Envía created para meterlo en el stream y lo saca de la cola CategoryCreatedEvent categoryCreatedEvent = CategoryDataUtil.getCategoryCreatedEvent(code + "7"); kafkaTemplate.send(category_topic, categoryCreatedEvent.getAggregateId(), categoryCreatedEvent); blockingQueue.poll(10, TimeUnit.SECONDS); blockingQueue.poll(30, TimeUnit.SECONDS); Thread.sleep(8000); PrepareRollbackEvent event = CategoryDataUtil.getPrepareRollbackEvent(code + "7"); Loading
atlas-commands/src/test/java/es/redmic/test/atlascommands/integration/themeinspire/ThemeInspireCommandHandlerTest.java +3 −1 Original line number Diff line number Diff line Loading @@ -376,7 +376,9 @@ public class ThemeInspireCommandHandlerTest extends KafkaBaseIntegrationTest { ThemeInspireCreatedEvent themeInspireCreatedEvent = ThemeInspireDataUtil .getThemeInspireCreatedEvent(code + "7"); kafkaTemplate.send(theme_inspire_topic, themeInspireCreatedEvent.getAggregateId(), themeInspireCreatedEvent); blockingQueue.poll(10, TimeUnit.SECONDS); blockingQueue.poll(30, TimeUnit.SECONDS); Thread.sleep(8000); PrepareRollbackEvent event = ThemeInspireDataUtil.getPrepareRollbackEvent(code + "7"); Loading