Merge pull request #12 from FINTLabs/FFS-285

FFS-285
FINTLabs · Sep 21, 2023 · 4b74c0b · 4b74c0b
2 parents 59ba3d6 + 498830e
commit 4b74c0b
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 0 deletions.
diff --git 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
@@ -55,6 +55,11 @@ public ConcurrentMessageListenerContainer<String, Object> instanceMappedEventCon
         return createInfoEventListener(INSTANCE_MAPPED);
     }
 
+    @Bean
+    public ConcurrentMessageListenerContainer<String, Object> instanceReadyForDispatchEventConsumer() {
+        return createInfoEventListener(INSTANCE_READY_FOR_DISPATCH);
+    }
+
     @Bean
     public ConcurrentMessageListenerContainer<String, Object> 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
@@ -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)
         ));