diff --git a/CHANGELOG.md b/CHANGELOG.md index a6a05b3fe..d812b9554 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,10 @@ on [Keep a CHANGELOG](http://keepachangelog.com/). This project adheres to ## [Unreleased] +## [1.1.0-M8] - 2019-01-08 +### Fixed +- Fixed error of two subscriptions created in database for each subscription + ## [1.1.0-M7] - 2019-01-03 ### Changed - Fix checksum issue with liquibase scripts diff --git a/event-sourcing/subscription-manager/src/main/java/uk/gov/justice/services/event/sourcing/subscription/manager/EventCatchupProcessor.java b/event-sourcing/subscription-manager/src/main/java/uk/gov/justice/services/event/sourcing/subscription/manager/EventCatchupProcessor.java index c2987045d..eece9a526 100644 --- a/event-sourcing/subscription-manager/src/main/java/uk/gov/justice/services/event/sourcing/subscription/manager/EventCatchupProcessor.java +++ b/event-sourcing/subscription-manager/src/main/java/uk/gov/justice/services/event/sourcing/subscription/manager/EventCatchupProcessor.java @@ -36,7 +36,7 @@ public void performEventCatchup(final Subscription subscription) { logger.info("Event catchup started"); logger.info("Performing catchup of events..."); - final long eventNumber = subscriptionsRepository.getOrInitialiseCurrentEventNumber(subscription.getName()); + final long eventNumber = subscriptionsRepository.getOrInitialiseCurrentEventNumber(subscription.getEventSourceName()); final int totalEventsProcessed = eventSource.findEventsSince(eventNumber) .mapToInt(transactionalEventProcessor::processWithEventBuffer) diff --git a/event-sourcing/subscription-manager/src/test/java/uk/gov/justice/services/event/sourcing/subscription/manager/EventCatchupProcessorTest.java b/event-sourcing/subscription-manager/src/test/java/uk/gov/justice/services/event/sourcing/subscription/manager/EventCatchupProcessorTest.java index ee38cf16f..5bd50c69c 100644 --- a/event-sourcing/subscription-manager/src/test/java/uk/gov/justice/services/event/sourcing/subscription/manager/EventCatchupProcessorTest.java +++ b/event-sourcing/subscription-manager/src/test/java/uk/gov/justice/services/event/sourcing/subscription/manager/EventCatchupProcessorTest.java @@ -43,7 +43,6 @@ public class EventCatchupProcessorTest { @Test public void shouldFetchAllMissingEventsAndProcess() throws Exception { - final String subscriptionName = "subscriptionName"; final String eventSourceName = "event source"; final long eventNumber = 983745987L; @@ -56,8 +55,7 @@ public void shouldFetchAllMissingEventsAndProcess() throws Exception { when(subscription.getEventSourceName()).thenReturn(eventSourceName); when(eventSourceProvider.getEventSource(eventSourceName)).thenReturn(eventSource); - when(subscription.getName()).thenReturn(subscriptionName); - when(subscriptionsRepository.getOrInitialiseCurrentEventNumber(subscriptionName)).thenReturn(eventNumber); + when(subscriptionsRepository.getOrInitialiseCurrentEventNumber(eventSourceName)).thenReturn(eventNumber); when(eventSource.findEventsSince(eventNumber)).thenReturn(Stream.of(event_1, event_2, event_3)); when(transactionalEventProcessor.processWithEventBuffer(any(JsonEnvelope.class))).thenReturn(1);