Upgrade dependencies, including framework 3.0.0

CJSCommonPlatform · Jan 19, 2018 · 0d1037c · 0d1037c
1 parent 386fb2d
commit 0d1037c
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/pom.xml b/pom.xml
@@ -15,10 +15,10 @@
     <version>0.0.1-SNAPSHOT</version>
 
     <properties>
-        <framework.version>3.0.0-alpha-1</framework.version>
-        <common-bom.version>1.21.0</common-bom.version>
-        <utilities.version>1.10.0</utilities.version>
-        <test-utils.version>1.15.0</test-utils.version>
+        <framework.version>3.0.0</framework.version>
+        <common-bom.version>1.22.0</common-bom.version>
+        <utilities.version>1.11.0</utilities.version>
+        <test-utils.version>1.16.0</test-utils.version>
         <wildfly.swarm.version>2017.11.0</wildfly.swarm.version>
         <version.swarm.fraction-plugin>77</version.swarm.fraction-plugin>
         <test.utils.core.version>1.15.0</test.utils.core.version>

diff --git a/...ain/java/uk/gov/justice/framework/tools/transformation/TestEventStreamJdbcRepository.java b/...ain/java/uk/gov/justice/framework/tools/transformation/TestEventStreamJdbcRepository.java
@@ -2,6 +2,7 @@
 
 import static uk.gov.justice.services.test.utils.common.reflection.ReflectionUtils.setField;
 
+import uk.gov.justice.services.common.util.UtcClock;
 import uk.gov.justice.services.eventsourcing.repository.jdbc.eventstream.EventStreamJdbcRepository;
 import uk.gov.justice.services.jdbc.persistence.JdbcRepositoryHelper;
 
@@ -15,7 +16,7 @@ public TestEventStreamJdbcRepository(DataSource dataSource) {
         this.dbsource = dataSource;
         setField(this, "dataSource", dbsource);
         setField(this, "eventStreamJdbcRepositoryHelper", new JdbcRepositoryHelper());
-
+        setField(this, "clock", new UtcClock());
     }
 
     public DataSource getDatasource() {

diff --git a/.../justice/tools/eventsourcing/transformation/service/EventStreamTransformationService.java b/.../justice/tools/eventsourcing/transformation/service/EventStreamTransformationService.java
@@ -75,6 +75,7 @@ public UUID transformEventStream(final UUID streamId) throws EventStreamExceptio
 
                 eventSource.clearStream(streamId);
 
+                logger.info("transforming events on stream {}", streamId);
                 final Stream<JsonEnvelope> transformedEventStream = transform(events);
 
                 stream.append(transformedEventStream.map(this::clearEventVersion));
@@ -85,7 +86,7 @@ public UUID transformEventStream(final UUID streamId) throws EventStreamExceptio
             eventStream.close();
             return streamId;
         } else {
-            logger.info("Stream did not require transformation");
+            logger.debug("Stream {} did not require transformation", streamId);
             eventStream.close();
             return null;
         }