Merge pull request #216 from CJSCommonPlatform/cherry-pick-2.4.x

Cherry pick 2.4.x
CJSCommonPlatform · Jan 30, 2020 · 2159bb4 · 2159bb4
2 parents ae5385e + 77d6a5a
commit 2159bb4
Show file tree

Hide file tree

Showing 72 changed files with 817 additions and 621 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -10,6 +10,28 @@ on [Keep a CHANGELOG](http://keepachangelog.com/). This project adheres to
 - Updated framework-api to 4.2.1
 - Database cleaner updated to handle the latest system database tables
 
+## [2.4.8] - 2020-01-29
+### Changed
+- Inserts into the event-buffer no longer fails if there is a conflict; it just logs a warning
+
+## [2.4.7] - 2020-01-24
+### Changed
+- Event store now works with multiple event sources
+- Event store now compatible with contexts that do not have a command pillar
+- Extracted all command pillar SystemCommands into their own module
+
+## [2.4.6] - 2020-01-21
+### Added
+- Catchup for multiple components now run in order of component and subscription priority
+- Added event source name to catchup logger output
+### Fixed
+- Fixed catchup error where catchup was marked as complete after all subscriptions rather than all components
+
+## [2.4.5] - 2020-01-06
+### Removed
+- Remove mechanism to also drop/add trigger on SUSPEND/UNSUSPEND as it causes 
+many strange ejb database errors
+
 ## [2.4.4] - 2020-01-06
 ### Added
 - Added mechanism to also drop/add trigger to event_log table on SUSPEND/UNSUSPEND commands

diff --git a/...justice/services/event/buffer/core/repository/streambuffer/EventBufferJdbcRepository.java b/...justice/services/event/buffer/core/repository/streambuffer/EventBufferJdbcRepository.java
@@ -19,10 +19,12 @@
 import javax.inject.Inject;
 import javax.sql.DataSource;
 
+import org.slf4j.Logger;
+
 @ApplicationScoped
 public class EventBufferJdbcRepository {
 
-    private static final String INSERT = "INSERT INTO stream_buffer (stream_id, position, event, source, component) VALUES (?, ?, ?, ?, ?)";
+    private static final String INSERT = "INSERT INTO stream_buffer (stream_id, position, event, source, component) VALUES (?, ?, ?, ?, ?) ON CONFLICT DO NOTHING";
     private static final String SELECT_STREAM_BUFFER_BY_STREAM_ID_SOURCE_AND_COMPONENT = "SELECT stream_id, position, event, source, component FROM stream_buffer WHERE stream_id=? AND source=? AND component=? ORDER BY position";
     private static final String DELETE_BY_STREAM_ID_POSITION = "DELETE FROM stream_buffer WHERE stream_id=? AND position=? AND source=? AND component=?";
 
@@ -41,16 +43,21 @@ public class EventBufferJdbcRepository {
     @Inject
     private ViewStoreJdbcDataSourceProvider dataSourceProvider;
 
+    @Inject
+    private Logger logger;
+
     private DataSource dataSource;
 
     public EventBufferJdbcRepository() {}
 
     public EventBufferJdbcRepository(final JdbcResultSetStreamer jdbcResultSetStreamer,
                                      final PreparedStatementWrapperFactory preparedStatementWrapperFactory,
-                                     final DataSource dataSource) {
+                                     final DataSource dataSource,
+                                     final Logger logger) {
         this.jdbcResultSetStreamer = jdbcResultSetStreamer;
         this.dataSource = dataSource;
         this.preparedStatementWrapperFactory = preparedStatementWrapperFactory;
+        this.logger = logger;
     }
 
 
@@ -67,7 +74,11 @@ public void insert(final EventBufferEvent bufferedEvent) {
             ps.setString(3, bufferedEvent.getEvent());
             ps.setString(4, bufferedEvent.getSource());
             ps.setString(5, bufferedEvent.getComponent());
-            ps.executeUpdate();
+            final int rowsUpdated = ps.executeUpdate();
+            if (rowsUpdated == 0){
+                logger.warn("Event already present in event buffer. Ignoring");
+            }
+
         } catch (SQLException e) {
             throw new JdbcRepositoryException(format("Exception while storing event in the buffer: %s", bufferedEvent), e);
         }

diff --git a/...stice/services/event/buffer/core/repository/streambuffer/EventBufferJdbcRepositoryIT.java b/...stice/services/event/buffer/core/repository/streambuffer/EventBufferJdbcRepositoryIT.java
@@ -7,6 +7,7 @@
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.collection.IsCollectionWithSize.hasSize;
 import static org.junit.Assert.assertThat;
+import static org.mockito.Mockito.mock;
 
 import uk.gov.justice.services.jdbc.persistence.JdbcResultSetStreamer;
 import uk.gov.justice.services.jdbc.persistence.PreparedStatementWrapperFactory;
@@ -20,6 +21,7 @@
 
 import org.junit.Before;
 import org.junit.Test;
+import org.slf4j.Logger;
 
 public class EventBufferJdbcRepositoryIT {
 
@@ -32,7 +34,8 @@ public void initDatabase() throws Exception {
         eventBufferJdbcRepository = new EventBufferJdbcRepository(
                 new JdbcResultSetStreamer(),
                 new PreparedStatementWrapperFactory(),
-                dataSource);
+                dataSource,
+                mock(Logger.class));
 
         new DatabaseCleaner().cleanViewStoreTables("framework", "stream_buffer", "stream_status");
     }

diff --git a/...ice/services/event/buffer/core/repository/streambuffer/EventBufferJdbcRepositoryTest.java b/...ice/services/event/buffer/core/repository/streambuffer/EventBufferJdbcRepositoryTest.java
@@ -4,6 +4,7 @@
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.verifyZeroInteractions;
 import static org.mockito.Mockito.when;
 
 import uk.gov.justice.services.jdbc.persistence.JdbcRepositoryException;
@@ -29,11 +30,12 @@
 import org.mockito.Mock;
 import org.mockito.Spy;
 import org.mockito.runners.MockitoJUnitRunner;
+import org.slf4j.Logger;
 
 @RunWith(MockitoJUnitRunner.class)
 public class EventBufferJdbcRepositoryTest {
     private static final String SELECT_STREAM_BUFFER_BY_STREAM_ID_SOURCE_AND_COMPONENT = "SELECT stream_id, position, event, source, component FROM stream_buffer WHERE stream_id=? AND source=? AND component=? ORDER BY position";
-    private static final String INSERT = "INSERT INTO stream_buffer (stream_id, position, event, source, component) VALUES (?, ?, ?, ?, ?)";
+    private static final String INSERT = "INSERT INTO stream_buffer (stream_id, position, event, source, component) VALUES (?, ?, ?, ?, ?) ON CONFLICT DO NOTHING";
     private static final String DELETE_BY_STREAM_ID_POSITION = "DELETE FROM stream_buffer WHERE stream_id=? AND position=? AND source=? AND component=?";
 
     @Spy
@@ -57,6 +59,9 @@ public class EventBufferJdbcRepositoryTest {
     @Mock
     private JdbcResultSetStreamer jdbcResultSetStreamer;
 
+    @Mock
+    private Logger logger;
+
     @InjectMocks
     private EventBufferJdbcRepository eventBufferJdbcRepository;
 
@@ -72,8 +77,29 @@ public void initDatabase() throws Exception {
     public void shouldInsertEvent() throws SQLException {
         final String source = "source";
 
-        when(connection.prepareStatement(INSERT))
-                .thenReturn(preparedStatement);
+        when(connection.prepareStatement(INSERT)).thenReturn(preparedStatement);
+        when(preparedStatement.executeUpdate()).thenReturn(1);
+
+        final UUID streamId = randomUUID();
+        final long position = 1l;
+        eventBufferJdbcRepository.insert(new EventBufferEvent(streamId, position, "eventVersion_2", source, EVENT_LISTENER));
+
+        verify(preparedStatement).setObject(1, streamId);
+        verify(preparedStatement).setLong(2, position);
+        verify(preparedStatement).setString(3, "eventVersion_2");
+        verify(preparedStatement).setString(4, source);
+        verify(preparedStatement).setString(5, EVENT_LISTENER);
+        verify(preparedStatement).executeUpdate();
+        verifyZeroInteractions(logger);
+    }
+
+    @Test
+    public void shouldWarnIfInsertDoesNothing() throws SQLException {
+        final String source = "source";
+
+
+        when(connection.prepareStatement(INSERT)).thenReturn(preparedStatement);
+        when(preparedStatement.executeUpdate()).thenReturn(0);
 
         final UUID streamId = randomUUID();
         final long position = 1l;
@@ -85,6 +111,7 @@ public void shouldInsertEvent() throws SQLException {
         verify(preparedStatement).setString(4, source);
         verify(preparedStatement).setString(5, EVENT_LISTENER);
         verify(preparedStatement).executeUpdate();
+        verify(logger).warn("Event already present in event buffer. Ignoring");
     }
 
     @Test(expected = JdbcRepositoryException.class)

diff --git a/event-store-management/event-store-management-command-handler-extension/pom.xml b/event-store-management/event-store-management-command-handler-extension/pom.xml
@@ -0,0 +1,54 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>event-store-management</artifactId>
+        <groupId>uk.gov.justice.event-store</groupId>
+        <version>2.5.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>event-store-management-command-handler-extension</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>javax</groupId>
+            <artifactId>javaee-api</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>uk.gov.justice.services</groupId>
+            <artifactId>framework-management</artifactId>
+            <version>${framework.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>uk.gov.justice.event-store</groupId>
+            <artifactId>event-store-management-core</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>uk.gov.justice.event-store</groupId>
+            <artifactId>event-store-util</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>uk.gov.justice.event-store</groupId>
+            <artifactId>event-publisher-timer</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
+        <!-- Test dependencies -->
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>
diff --git a/...anagement/commands/AddTriggerCommand.java → ...anagement/commands/AddTriggerCommand.java b/...anagement/commands/AddTriggerCommand.java → ...anagement/commands/AddTriggerCommand.java
diff --git a/...nt/commands/DisablePublishingCommand.java → ...nt/commands/DisablePublishingCommand.java b/...nt/commands/DisablePublishingCommand.java → ...nt/commands/DisablePublishingCommand.java
diff --git a/...ent/commands/EnablePublishingCommand.java → ...ent/commands/EnablePublishingCommand.java b/...ent/commands/EnablePublishingCommand.java → ...ent/commands/EnablePublishingCommand.java
diff --git a/...gement/commands/RemoveTriggerCommand.java → ...gement/commands/RemoveTriggerCommand.java b/...gement/commands/RemoveTriggerCommand.java → ...gement/commands/RemoveTriggerCommand.java
diff --git a/...mands/ValidatePublishedEventsCommand.java → ...mands/ValidatePublishedEventsCommand.java b/...mands/ValidatePublishedEventsCommand.java → ...mands/ValidatePublishedEventsCommand.java
diff --git a/...observers/CommandHandlerQueueDrainer.java → ...uspension/CommandHandlerQueueDrainer.java b/...observers/CommandHandlerQueueDrainer.java → ...uspension/CommandHandlerQueueDrainer.java
@@ -1,11 +1,10 @@
-package uk.gov.justice.services.eventstore.management.shuttering.observers;
+package uk.gov.justice.services.eventstore.management.extension.suspension;
 
 import static java.lang.String.format;
 import static uk.gov.justice.services.management.suspension.api.SuspensionResult.suspensionFailed;
 import static uk.gov.justice.services.management.suspension.api.SuspensionResult.suspensionSucceeded;
 
 import uk.gov.justice.services.eventsourcing.util.jee.timer.StopWatchFactory;
-import uk.gov.justice.services.eventstore.management.shuttering.process.CommandHandlerQueueInterrogator;
 import uk.gov.justice.services.management.suspension.api.Suspendable;
 import uk.gov.justice.services.management.suspension.api.SuspensionResult;
 import uk.gov.justice.services.management.suspension.commands.SuspensionCommand;

diff --git a/...cess/CommandHandlerQueueInterrogator.java → ...sion/CommandHandlerQueueInterrogator.java b/...cess/CommandHandlerQueueInterrogator.java → ...sion/CommandHandlerQueueInterrogator.java
@@ -1,4 +1,4 @@
-package uk.gov.justice.services.eventstore.management.shuttering.process;
+package uk.gov.justice.services.eventstore.management.extension.suspension;
 
 import uk.gov.justice.services.common.polling.MultiIteratingPoller;
 import uk.gov.justice.services.common.polling.MultiIteratingPollerFactory;

diff --git a/...s/CommandHandlerQueueSupplierFactory.java → ...n/CommandHandlerQueueSupplierFactory.java b/...s/CommandHandlerQueueSupplierFactory.java → ...n/CommandHandlerQueueSupplierFactory.java
@@ -1,4 +1,4 @@
-package uk.gov.justice.services.eventstore.management.shuttering.process;
+package uk.gov.justice.services.eventstore.management.extension.suspension;
 
 import uk.gov.justice.services.messaging.jms.JmsCommandHandlerDestinationNameProvider;
 import uk.gov.justice.services.messaging.jms.JmsQueueBrowser;

diff --git a/...shing/EnablePublishingCommandHandler.java → ...shing/EnablePublishingCommandHandler.java b/...shing/EnablePublishingCommandHandler.java → ...shing/EnablePublishingCommandHandler.java
diff --git a/...publishing/EnablePublishingProcessor.java → ...publishing/EnablePublishingProcessor.java b/...publishing/EnablePublishingProcessor.java → ...publishing/EnablePublishingProcessor.java
diff --git a/...agement/publishing/PublishingEnabler.java → ...agement/publishing/PublishingEnabler.java b/...agement/publishing/PublishingEnabler.java → ...agement/publishing/PublishingEnabler.java
diff --git a/...trigger/TriggerManagementStartupBean.java → ...trigger/TriggerManagementStartupBean.java b/...trigger/TriggerManagementStartupBean.java → ...trigger/TriggerManagementStartupBean.java
diff --git a/...mands/AddRemoveTriggerCommandHandler.java → ...mands/AddRemoveTriggerCommandHandler.java b/...mands/AddRemoveTriggerCommandHandler.java → ...mands/AddRemoveTriggerCommandHandler.java
diff --git a/...ValidatePublishedEventCommandHandler.java → ...ValidatePublishedEventCommandHandler.java b/...ValidatePublishedEventCommandHandler.java → ...ValidatePublishedEventCommandHandler.java
diff --git a/...ation/process/EventValidationProcess.java → ...ation/process/EventValidationProcess.java b/...ation/process/EventValidationProcess.java → ...ation/process/EventValidationProcess.java
diff --git a/...nt/validation/process/EventValidator.java → ...nt/validation/process/EventValidator.java b/...nt/validation/process/EventValidator.java → ...nt/validation/process/EventValidator.java
diff --git a/...lidation/process/JsonStringConverter.java → ...lidation/process/JsonStringConverter.java b/...lidation/process/JsonStringConverter.java → ...lidation/process/JsonStringConverter.java
diff --git a/...ation/process/MissingSchemaException.java → ...ation/process/MissingSchemaException.java b/...ation/process/MissingSchemaException.java → ...ation/process/MissingSchemaException.java
diff --git a/...ion/process/MissingSchemaIdException.java → ...ion/process/MissingSchemaIdException.java b/...ion/process/MissingSchemaIdException.java → ...ion/process/MissingSchemaIdException.java
diff --git a/...nt/validation/process/SchemaIdFinder.java → ...nt/validation/process/SchemaIdFinder.java b/...nt/validation/process/SchemaIdFinder.java → ...nt/validation/process/SchemaIdFinder.java
diff --git a/...tion/process/SchemaIdMappingProvider.java → ...tion/process/SchemaIdMappingProvider.java b/...tion/process/SchemaIdMappingProvider.java → ...tion/process/SchemaIdMappingProvider.java
diff --git a/...nt/validation/process/SchemaProvider.java → ...nt/validation/process/SchemaProvider.java b/...nt/validation/process/SchemaProvider.java → ...nt/validation/process/SchemaProvider.java
diff --git a/...idation/process/SingleEventValidator.java → ...idation/process/SingleEventValidator.java b/...idation/process/SingleEventValidator.java → ...idation/process/SingleEventValidator.java
diff --git a/...t/validation/process/ValidationError.java → ...t/validation/process/ValidationError.java b/...t/validation/process/ValidationError.java → ...t/validation/process/ValidationError.java
diff --git a/...nt/event-store-management-command-handler-extension/src/main/resources/META-INF/beans.xml b/...nt/event-store-management-command-handler-extension/src/main/resources/META-INF/beans.xml
@@ -0,0 +1,8 @@
+<!-- Marker file indicating CDI should be enabled -->
+
+<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns="http://xmlns.jcp.org/xml/ns/javaee"
+       xsi:schemaLocation="
+      http://xmlns.jcp.org/xml/ns/javaee
+      http://xmlns.jcp.org/xml/ns/javaee/beans_1_1.xsd" bean-discovery-mode="all">
+</beans>
diff --git a/...rvers/CommandHandlerQueueDrainerTest.java → ...nsion/CommandHandlerQueueDrainerTest.java b/...rvers/CommandHandlerQueueDrainerTest.java → ...nsion/CommandHandlerQueueDrainerTest.java
@@ -1,6 +1,7 @@
-package uk.gov.justice.services.eventstore.management.shuttering.observers;
+package uk.gov.justice.services.eventstore.management.extension.suspension;
 
 import static java.util.Optional.empty;
+import static java.util.UUID.randomUUID;
 import static org.hamcrest.CoreMatchers.is;
 import static org.junit.Assert.assertThat;
 import static org.mockito.Mockito.inOrder;
@@ -10,7 +11,6 @@
 import static uk.gov.justice.services.jmx.api.domain.CommandState.COMMAND_FAILED;
 
 import uk.gov.justice.services.eventsourcing.util.jee.timer.StopWatchFactory;
-import uk.gov.justice.services.eventstore.management.shuttering.process.CommandHandlerQueueInterrogator;
 import uk.gov.justice.services.management.suspension.api.SuspensionResult;
 import uk.gov.justice.services.management.suspension.commands.SuspensionCommand;
 
@@ -50,7 +50,7 @@ public void shouldSuspendButNotUnsuspend() throws Exception {
     @Test
     public void shouldWaitForCommandHandlerQueueToDrainAndReturnSuccess() throws Exception {
 
-        final UUID commandId = UUID.randomUUID();
+        final UUID commandId = randomUUID();
         final StopWatch stopWatch = mock(StopWatch.class);
         final SuspensionCommand suspensionCommand = mock(SuspensionCommand.class);
 
@@ -79,7 +79,7 @@ public void shouldWaitForCommandHandlerQueueToDrainAndReturnSuccess() throws Exc
     @Test
     public void shouldReturnFailureIfQueueDoesNotDrainInTime() throws Exception {
 
-        final UUID commandId = UUID.randomUUID();
+        final UUID commandId = randomUUID();
         final StopWatch stopWatch = mock(StopWatch.class);
         final SuspensionCommand applicationShutteringCommand = mock(SuspensionCommand.class);
 

diff --git a/.../CommandHandlerQueueInterrogatorTest.java → .../CommandHandlerQueueInterrogatorTest.java b/.../CommandHandlerQueueInterrogatorTest.java → .../CommandHandlerQueueInterrogatorTest.java
@@ -1,4 +1,4 @@
-package uk.gov.justice.services.eventstore.management.shuttering.process;
+package uk.gov.justice.services.eventstore.management.extension.suspension;
 
 import static org.hamcrest.CoreMatchers.is;
 import static org.hamcrest.MatcherAssert.assertThat;

diff --git a/...mmandHandlerQueueSupplierFactoryTest.java → ...mmandHandlerQueueSupplierFactoryTest.java b/...mmandHandlerQueueSupplierFactoryTest.java → ...mmandHandlerQueueSupplierFactoryTest.java
@@ -1,4 +1,4 @@
-package uk.gov.justice.services.eventstore.management.shuttering.process;
+package uk.gov.justice.services.eventstore.management.extension.suspension;
 
 import static org.hamcrest.CoreMatchers.is;
 import static org.hamcrest.MatcherAssert.assertThat;

diff --git a/...g/EnablePublishingCommandHandlerTest.java → ...g/EnablePublishingCommandHandlerTest.java b/...g/EnablePublishingCommandHandlerTest.java → ...g/EnablePublishingCommandHandlerTest.java
diff --git a/...ishing/EnablePublishingProcessorTest.java → ...ishing/EnablePublishingProcessorTest.java b/...ishing/EnablePublishingProcessorTest.java → ...ishing/EnablePublishingProcessorTest.java
diff --git a/...ent/publishing/PublishingEnablerTest.java → ...ent/publishing/PublishingEnablerTest.java b/...ent/publishing/PublishingEnablerTest.java → ...ent/publishing/PublishingEnablerTest.java
diff --git a/...ger/TriggerManagementStartupBeanTest.java → ...ger/TriggerManagementStartupBeanTest.java b/...ger/TriggerManagementStartupBeanTest.java → ...ger/TriggerManagementStartupBeanTest.java
diff --git a/...s/AddRemoveTriggerCommandHandlerTest.java → ...s/AddRemoveTriggerCommandHandlerTest.java b/...s/AddRemoveTriggerCommandHandlerTest.java → ...s/AddRemoveTriggerCommandHandlerTest.java
diff --git a/...datePublishedEventCommandHandlerTest.java → ...datePublishedEventCommandHandlerTest.java b/...datePublishedEventCommandHandlerTest.java → ...datePublishedEventCommandHandlerTest.java
diff --git a/...n/process/EventValidationProcessTest.java → ...n/process/EventValidationProcessTest.java b/...n/process/EventValidationProcessTest.java → ...n/process/EventValidationProcessTest.java
diff --git a/...alidation/process/EventValidatorTest.java → ...alidation/process/EventValidatorTest.java b/...alidation/process/EventValidatorTest.java → ...alidation/process/EventValidatorTest.java
diff --git a/...tion/process/JsonStringConverterTest.java → ...tion/process/JsonStringConverterTest.java b/...tion/process/JsonStringConverterTest.java → ...tion/process/JsonStringConverterTest.java
diff --git a/...alidation/process/SchemaIdFinderTest.java → ...alidation/process/SchemaIdFinderTest.java b/...alidation/process/SchemaIdFinderTest.java → ...alidation/process/SchemaIdFinderTest.java
diff --git a/.../process/SchemaIdMappingProviderTest.java → .../process/SchemaIdMappingProviderTest.java b/.../process/SchemaIdMappingProviderTest.java → .../process/SchemaIdMappingProviderTest.java
diff --git a/...alidation/process/SchemaProviderTest.java → ...alidation/process/SchemaProviderTest.java b/...alidation/process/SchemaProviderTest.java → ...alidation/process/SchemaProviderTest.java
diff --git a/...ion/process/SingleEventValidatorTest.java → ...ion/process/SingleEventValidatorTest.java b/...ion/process/SingleEventValidatorTest.java → ...ion/process/SingleEventValidatorTest.java
diff --git a/event-store-management/event-store-management-core/pom.xml b/event-store-management/event-store-management-core/pom.xml
@@ -54,11 +54,6 @@
             <artifactId>event-store-management-events</artifactId>
             <version>${project.version}</version>
         </dependency>
-        <dependency>
-            <groupId>uk.gov.justice.event-store</groupId>
-            <artifactId>event-publisher-timer</artifactId>
-            <version>${project.version}</version>
-        </dependency>
         <dependency>
             <groupId>uk.gov.justice.event-store</groupId>
             <artifactId>event-tracking-service</artifactId>