Update to use refactored event-store

CJSCommonPlatform · Apr 24, 2019 · 757967d · 757967d
1 parent e27f1c9
commit 757967d
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 18 deletions.
diff --git a/...a/uk/gov/justice/services/eventsourcing/repository/jdbc/event/EventRepositoryFactory.java b/...a/uk/gov/justice/services/eventsourcing/repository/jdbc/event/EventRepositoryFactory.java
@@ -6,20 +6,24 @@
 import uk.gov.justice.services.eventsourcing.repository.jdbc.AnsiSQLEventLogInsertionStrategy;
 import uk.gov.justice.services.jdbc.persistence.JdbcResultSetStreamer;
 import uk.gov.justice.services.jdbc.persistence.PreparedStatementWrapperFactory;
+import uk.gov.justice.services.test.utils.persistence.TestEventStoreDefaultDataSourceProvider;
 
 import javax.sql.DataSource;
 
 public class EventRepositoryFactory {
 
     public EventJdbcRepository getEventJdbcRepository(final DataSource dataSource) {
-        final EventJdbcRepository eventJdbcRepository = new EventJdbcRepository(
-                new AnsiSQLEventLogInsertionStrategy(),
-                new JdbcResultSetStreamer(),
-                new PreparedStatementWrapperFactory(),
-                dataSource,
-                getLogger(EventJdbcRepository.class));
-
-        setField(eventJdbcRepository, "dataSource", dataSource);
+
+        final EventJdbcRepository eventJdbcRepository = new EventJdbcRepository();
+
+        final TestEventStoreDefaultDataSourceProvider testEventStoreDefaultDataSourceProvider = new TestEventStoreDefaultDataSourceProvider();
+        testEventStoreDefaultDataSourceProvider.setDataSource(dataSource);
+
+        setField(eventJdbcRepository, "eventInsertionStrategy", new AnsiSQLEventLogInsertionStrategy());
+        setField(eventJdbcRepository, "jdbcResultSetStreamer", new JdbcResultSetStreamer());
+        setField(eventJdbcRepository, "preparedStatementWrapperFactory", new PreparedStatementWrapperFactory());
+        setField(eventJdbcRepository, "eventStoreDefaultDataSourceProvider", testEventStoreDefaultDataSourceProvider);
+        setField(eventJdbcRepository, "logger", getLogger(EventJdbcRepository.class));
 
         return eventJdbcRepository;
     }

diff --git a/...ustice/services/eventsourcing/repository/jdbc/event/EventStreamJdbsRepositoryFactory.java b/...ustice/services/eventsourcing/repository/jdbc/event/EventStreamJdbsRepositoryFactory.java
@@ -6,20 +6,23 @@
 import uk.gov.justice.services.eventsourcing.repository.jdbc.eventstream.EventStreamJdbcRepository;
 import uk.gov.justice.services.jdbc.persistence.JdbcResultSetStreamer;
 import uk.gov.justice.services.jdbc.persistence.PreparedStatementWrapperFactory;
+import uk.gov.justice.services.test.utils.persistence.TestEventStoreDefaultDataSourceProvider;
 
 import javax.sql.DataSource;
 
 public class EventStreamJdbsRepositoryFactory {
 
     public EventStreamJdbcRepository getEventStreamJdbcRepository(final DataSource dataSource) {
 
-        final EventStreamJdbcRepository eventStreamJdbcRepository = new EventStreamJdbcRepository(
-                new JdbcResultSetStreamer(),
-                new PreparedStatementWrapperFactory(),
-                dataSource,
-                new UtcClock());
+        final EventStreamJdbcRepository eventStreamJdbcRepository = new EventStreamJdbcRepository();
 
-        setField(eventStreamJdbcRepository, "dataSource", dataSource);
+        final TestEventStoreDefaultDataSourceProvider testEventStoreDefaultDataSourceProvider = new TestEventStoreDefaultDataSourceProvider();
+        testEventStoreDefaultDataSourceProvider.setDataSource(dataSource);
+
+        setField(eventStreamJdbcRepository, "jdbcResultSetStreamer", new JdbcResultSetStreamer());
+        setField(eventStreamJdbcRepository, "preparedStatementWrapperFactory", new PreparedStatementWrapperFactory());
+        setField(eventStreamJdbcRepository, "eventStoreDefaultDataSourceProvider", testEventStoreDefaultDataSourceProvider);
+        setField(eventStreamJdbcRepository, "clock", new UtcClock());
 
         return eventStreamJdbcRepository;
     }

diff --git a/pom.xml b/pom.xml
@@ -31,12 +31,12 @@
     <properties>
         <cpp.repo.name>cake-shop</cpp.repo.name>
         <common-bom.version>1.28.0</common-bom.version>
-        <framework.version>6.0.0-M14</framework.version>
+        <framework.version>6.0.0-M16</framework.version>
         <embedded-artemis.version>1.2.0</embedded-artemis.version>
-        <event-store.version>2.0.0-M14</event-store.version>
-        <framework-generators.version>2.0.0-M11</framework-generators.version>
+        <event-store.version>2.0.0-SNAPSHOT</event-store.version>
+        <framework-generators.version>2.0.0-SNAPSHOT</framework-generators.version>
         <file.service.version>1.17.4</file.service.version>
-        <framework-api.version>4.0.0-M8</framework-api.version>
+        <framework-api.version>4.0.0-M10</framework-api.version>
         <generator-maven-plugin.version>2.6.2</generator-maven-plugin.version>
         <json-schema-catalog.version>1.6.0</json-schema-catalog.version>
         <jboss-ejb3-ext-api.version>2.2.0.Final</jboss-ejb3-ext-api.version>