Commit 3e0d5a35 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade espera por mensajes de kafka en los tests

parent 139a4fbc

atlas-commands/src/test/java/es/redmic/test/atlascommands/integration/category/CategoryCommandHandlerTest.java

+4 −0
Original line number Diff line number Diff line
@@ -457,6 +457,8 @@ public class CategoryCommandHandlerTest extends KafkaBaseIntegrationTest { 
		kafkaTemplate.send(category_topic, categoryCreatedEvent.getAggregateId(), categoryCreatedEvent);

		blockingQueue.poll(30, TimeUnit.SECONDS);



		Thread.sleep(8000);



		try {

			Whitebox.invokeMethod(categoryCommandHandler, "update", categoryCreatedEvent.getAggregateId(),

					new UpdateCategoryCommand(categoryCreatedEvent.getCategory()));
@@ -577,6 +579,8 @@ public class CategoryCommandHandlerTest extends KafkaBaseIntegrationTest { 
		kafkaTemplate.send(category_topic, categoryCreatedEvent.getAggregateId(), categoryCreatedEvent);

		blockingQueue.poll(30, TimeUnit.SECONDS);



		Thread.sleep(8000);



		try {

			Whitebox.invokeMethod(categoryCommandHandler, "update", categoryCreatedEvent.getAggregateId(),

					new DeleteCategoryCommand(categoryCreatedEvent.getCategory().getId()));

atlas-commands/src/test/java/es/redmic/test/atlascommands/integration/layer/LayerCommandHandlerTest.java

+6 −4
Original line number Diff line number Diff line
@@ -628,12 +628,12 @@ public class LayerCommandHandlerTest extends KafkaBaseIntegrationTest { 
		ThemeInspireCreatedEvent themeInspireCreatedEvent = ThemeInspireDataUtil.getThemeInspireCreatedEvent("cc");

		kafkaTemplate.send(theme_inspire_topic, themeInspireCreatedEvent.getAggregateId(), themeInspireCreatedEvent);



		Thread.sleep(4000);



		LayerCreatedEvent layerCreatedEvent = LayerDataUtil.getLayerCreatedEvent(code + "11");

		kafkaTemplate.send(layer_topic, layerCreatedEvent.getAggregateId(), layerCreatedEvent);

		blockingQueue.poll(30, TimeUnit.SECONDS);



		Thread.sleep(8000);



		try {

			Whitebox.invokeMethod(layerCommandHandler, "update", layerCreatedEvent.getAggregateId(),

					new UpdateLayerCommand(layerCreatedEvent.getLayer()));
@@ -771,12 +771,12 @@ public class LayerCommandHandlerTest extends KafkaBaseIntegrationTest { 
		ThemeInspireCreatedEvent themeInspireCreatedEvent = ThemeInspireDataUtil.getThemeInspireCreatedEvent("cc");

		kafkaTemplate.send(theme_inspire_topic, themeInspireCreatedEvent.getAggregateId(), themeInspireCreatedEvent);



		Thread.sleep(4000);



		LayerCreatedEvent layerCreatedEvent = LayerDataUtil.getLayerCreatedEvent(code + "15");

		kafkaTemplate.send(layer_topic, layerCreatedEvent.getAggregateId(), layerCreatedEvent);

		blockingQueue.poll(30, TimeUnit.SECONDS);



		Thread.sleep(4000);



		try {

			Whitebox.invokeMethod(layerCommandHandler, "refresh", new RefreshLayerCommand(

					layerCreatedEvent.getAggregateId(), LayerDataUtil.getLayerWMS(code + "15")));
@@ -904,6 +904,8 @@ public class LayerCommandHandlerTest extends KafkaBaseIntegrationTest { 
		kafkaTemplate.send(layer_topic, layerCreatedEvent.getAggregateId(), layerCreatedEvent);

		blockingQueue.poll(30, TimeUnit.SECONDS);



		Thread.sleep(8000);



		try {

			Whitebox.invokeMethod(layerCommandHandler, "update", layerCreatedEvent.getAggregateId(),

					new DeleteLayerCommand(layerCreatedEvent.getLayer().getId()));

atlas-commands/src/test/java/es/redmic/test/atlascommands/integration/themeinspire/ThemeInspireCommandHandlerTest.java

+4 −0
Original line number Diff line number Diff line
@@ -503,6 +503,8 @@ public class ThemeInspireCommandHandlerTest extends KafkaBaseIntegrationTest { 
		kafkaTemplate.send(theme_inspire_topic, themeInspireCreatedEvent.getAggregateId(), themeInspireCreatedEvent);

		blockingQueue.poll(30, TimeUnit.SECONDS);



		Thread.sleep(8000);



		try {

			Whitebox.invokeMethod(themeInspireCommandHandler, "update", themeInspireCreatedEvent.getAggregateId(),

					new UpdateThemeInspireCommand(themeInspireCreatedEvent.getThemeInspire()));
@@ -629,6 +631,8 @@ public class ThemeInspireCommandHandlerTest extends KafkaBaseIntegrationTest { 
		kafkaTemplate.send(theme_inspire_topic, themeInspireCreatedEvent.getAggregateId(), themeInspireCreatedEvent);

		blockingQueue.poll(30, TimeUnit.SECONDS);



		Thread.sleep(8000);



		try {

			Whitebox.invokeMethod(themeInspireCommandHandler, "update", themeInspireCreatedEvent.getAggregateId(),

					new DeleteThemeInspireCommand(themeInspireCreatedEvent.getThemeInspire().getId()));