Merge pull request #199 from CJSCommonPlatform/log-message-for-catchup

Add catchup Log message to show that all active events are now waitin…
CJSCommonPlatform · Nov 22, 2019 · c5798d7 · c5798d7
2 parents a31be22 + b72a990
commit c5798d7
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -4,6 +4,8 @@ on [Keep a CHANGELOG](http://keepachangelog.com/). This project adheres to
 [Semantic Versioning](http://semver.org/).
 
 ## [Unreleased]
+### Added
+- Catchup Log message to show that all active events are now waiting to be consumed
 
 ## [2.4.1] - 2019-11-20
 ### Changed

diff --git a/.../uk/gov/justice/services/eventstore/management/catchup/process/EventCatchupProcessor.java b/.../uk/gov/justice/services/eventstore/management/catchup/process/EventCatchupProcessor.java
@@ -72,6 +72,8 @@ public void performEventCatchup(final CatchupSubscriptionContext catchupSubscrip
 
         }).sum();
 
+        logger.info(format("%d active PublishedEvents queued for publishing", totalEventsProcessed));
+        logger.info("Waiting for publishing consumer completion...");
         concurrentEventStreamConsumerManager.waitForCompletion();
 
         final CatchupCompletedForSubscriptionEvent event = new CatchupCompletedForSubscriptionEvent(

diff --git a/...gov/justice/services/eventstore/management/catchup/process/EventCatchupProcessorTest.java b/...gov/justice/services/eventstore/management/catchup/process/EventCatchupProcessorTest.java
@@ -131,6 +131,8 @@ public void shouldFetchAllMissingEventsAndProcess() throws Exception {
 
         verify(logger).info("Finding all missing events for event source 'event source', component 'EVENT_LISTENER");
         verify(logger).info("CATCHUP for Event Number: " + (eventNumberFrom + 1L));
+        verify(logger).info("3 active PublishedEvents queued for publishing");
+        verify(logger).info("Waiting for publishing consumer completion...");
     }
 
     @Test