diff --git a/src/main/java/no/fintlabs/EventTopicNames.java b/src/main/java/no/fintlabs/EventTopicNames.java index d86ed7b..13091a5 100644 --- a/src/main/java/no/fintlabs/EventTopicNames.java +++ b/src/main/java/no/fintlabs/EventTopicNames.java @@ -9,6 +9,7 @@ private EventTopicNames() { public static String INSTANCE_REGISTERED = "instance-registered"; public static String INSTANCE_REQUESTED_FOR_RETRY = "instance-requested-for-retry"; public static String INSTANCE_MAPPED = "instance-mapped"; + public static String INSTANCE_READY_FOR_DISPATCH = "instance-ready-for-dispatch"; public static String INSTANCE_DISPATCHED = "instance-dispatched"; public static String INSTANCE_RECEIVAL_ERROR = "instance-receival-error"; diff --git a/src/main/java/no/fintlabs/consumers/InfoEventConsumerConfiguration.java b/src/main/java/no/fintlabs/consumers/InfoEventConsumerConfiguration.java index 65f07a8..a6ac706 100644 --- a/src/main/java/no/fintlabs/consumers/InfoEventConsumerConfiguration.java +++ b/src/main/java/no/fintlabs/consumers/InfoEventConsumerConfiguration.java @@ -55,6 +55,11 @@ public ConcurrentMessageListenerContainer instanceMappedEventCon return createInfoEventListener(INSTANCE_MAPPED); } + @Bean + public ConcurrentMessageListenerContainer instanceReadyForDispatchEventConsumer() { + return createInfoEventListener(INSTANCE_READY_FOR_DISPATCH); + } + @Bean public ConcurrentMessageListenerContainer instanceDispatchedEventConsumer() { return createInfoEventListener(INSTANCE_DISPATCHED); diff --git a/src/test/java/no/fintlabs/repositories/EventRepositoryTest.java b/src/test/java/no/fintlabs/repositories/EventRepositoryTest.java index ed5356c..ab99060 100644 --- a/src/test/java/no/fintlabs/repositories/EventRepositoryTest.java +++ b/src/test/java/no/fintlabs/repositories/EventRepositoryTest.java @@ -162,6 +162,7 @@ public void shouldReturnNumberOfDispatchedInstances() { createNamedEvent("1", "1", EventType.INFO, INSTANCE_RECEIVED), createNamedEvent("1", "1", EventType.INFO, INSTANCE_REGISTERED), createNamedEvent("1", "1", EventType.INFO, INSTANCE_MAPPED), + createNamedEvent("1", "1", EventType.INFO, INSTANCE_READY_FOR_DISPATCH), createNamedEvent("1", "1", EventType.INFO, INSTANCE_DISPATCHED), createNamedEvent("1", "2", EventType.INFO, INSTANCE_RECEIVED), @@ -171,12 +172,14 @@ public void shouldReturnNumberOfDispatchedInstances() { createNamedEvent("2", "3", EventType.INFO, INSTANCE_RECEIVED), createNamedEvent("2", "3", EventType.INFO, INSTANCE_REGISTERED), createNamedEvent("2", "3", EventType.INFO, INSTANCE_MAPPED), + createNamedEvent("2", "3", EventType.INFO, INSTANCE_READY_FOR_DISPATCH), createNamedEvent("2", "3", EventType.INFO, INSTANCE_DISPATCHED), createNamedEvent("2", "3", EventType.INFO, INSTANCE_DISPATCHED), createNamedEvent("2", "4", EventType.INFO, INSTANCE_RECEIVED), createNamedEvent("2", "4", EventType.INFO, INSTANCE_REGISTERED), createNamedEvent("2", "4", EventType.INFO, INSTANCE_MAPPED), + createNamedEvent("2", "4", EventType.INFO, INSTANCE_READY_FOR_DISPATCH), createNamedEvent("2", "4", EventType.INFO, INSTANCE_DISPATCHED) )); @@ -191,6 +194,7 @@ public void shouldReturnNumberOfDispatchedInstancesPerIntegrationId() { createNamedEvent("1", "1", EventType.INFO, INSTANCE_RECEIVED), createNamedEvent("1", "1", EventType.INFO, INSTANCE_REGISTERED), createNamedEvent("1", "1", EventType.INFO, INSTANCE_MAPPED), + createNamedEvent("1", "1", EventType.INFO, INSTANCE_READY_FOR_DISPATCH), createNamedEvent("1", "1", EventType.INFO, INSTANCE_DISPATCHED), createNamedEvent("1", "2", EventType.INFO, INSTANCE_RECEIVED), @@ -200,12 +204,14 @@ public void shouldReturnNumberOfDispatchedInstancesPerIntegrationId() { createNamedEvent("2", "3", EventType.INFO, INSTANCE_RECEIVED), createNamedEvent("2", "3", EventType.INFO, INSTANCE_REGISTERED), createNamedEvent("2", "3", EventType.INFO, INSTANCE_MAPPED), + createNamedEvent("2", "3", EventType.INFO, INSTANCE_READY_FOR_DISPATCH), createNamedEvent("2", "3", EventType.INFO, INSTANCE_DISPATCHED), createNamedEvent("2", "3", EventType.INFO, INSTANCE_DISPATCHED), createNamedEvent("2", "4", EventType.INFO, INSTANCE_RECEIVED), createNamedEvent("2", "4", EventType.INFO, INSTANCE_REGISTERED), createNamedEvent("2", "4", EventType.INFO, INSTANCE_MAPPED), + createNamedEvent("2", "4", EventType.INFO, INSTANCE_READY_FOR_DISPATCH), createNamedEvent("2", "4", EventType.INFO, INSTANCE_DISPATCHED) ));