Merge pull request #16 from dartartem/wip-separate-cdc

Wip separate cdc

build.gradle

@@ -46,6 +46,7 @@ subprojects {
     repositories {
         mavenCentral()
         maven { url "http://mavenrepo.eventuate.io/release"}
+        eventuateMavenRepoUrl.split(',').each { repoUrl -> maven { url repoUrl } }
     }
 
     dependencies {

eventuate-client-java-common-impl/build.gradle

@@ -3,6 +3,9 @@ apply plugin: PrivateModulePlugin
 dependencies {
     compile project(":eventuate-client-java")
 
+    compile "io.eventuate.common:eventuate-common-json-mapper:$eventuateCommonVersion"
+    compile "io.eventuate.common:eventuate-common-id:$eventuateCommonVersion"
+
     compile "com.fasterxml.jackson.core:jackson-databind:2.8.8"
     compile "com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.8.8"
 }

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/AggregateCrud.java

@@ -1,6 +1,7 @@
 package io.eventuate.javaclient.commonimpl;
 
 import io.eventuate.*;
+import io.eventuate.common.id.Int128;
 
 import java.util.List;
 import java.util.Optional;

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/AggregateCrudMapping.java

@@ -3,10 +3,11 @@
 import io.eventuate.Event;
 import io.eventuate.EventWithMetadata;
 import io.eventuate.FindOptions;
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 import io.eventuate.SaveOptions;
 import io.eventuate.Snapshot;
 import io.eventuate.UpdateOptions;
+import io.eventuate.common.json.mapper.JSonMapper;
 
 import java.util.List;
 import java.util.Map;

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/DefaultSerializedEventDeserializer.java

@@ -3,6 +3,7 @@
 import io.eventuate.DispatchedEvent;
 import io.eventuate.EndOfCurrentEventsReachedEvent;
 import io.eventuate.Event;
+import io.eventuate.common.json.mapper.JSonMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/EntityIdVersionAndEventIds.java

@@ -1,7 +1,7 @@
 package io.eventuate.javaclient.commonimpl;
 
 import io.eventuate.EntityIdAndVersion;
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 import org.apache.commons.lang.builder.EqualsBuilder;
 import org.apache.commons.lang.builder.HashCodeBuilder;
 import org.apache.commons.lang.builder.ToStringBuilder;

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/EventIdTypeAndData.java

@@ -1,6 +1,6 @@
 package io.eventuate.javaclient.commonimpl;
 
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 import org.apache.commons.lang.builder.EqualsBuilder;
 import org.apache.commons.lang.builder.HashCodeBuilder;
 import org.apache.commons.lang.builder.ToStringBuilder;

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/EventuateAggregateStoreImpl.java

@@ -1,6 +1,8 @@
 package io.eventuate.javaclient.commonimpl;
 
 import io.eventuate.*;
+import io.eventuate.common.id.Int128;
+import io.eventuate.common.json.mapper.JSonMapper;
 import io.eventuate.javaclient.commonimpl.schemametadata.EmptyEventSchemaMetadataManager;
 import io.eventuate.javaclient.commonimpl.schemametadata.EventSchemaMetadataManager;
 

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/SerializedEvent.java

@@ -1,7 +1,7 @@
 package io.eventuate.javaclient.commonimpl;
 
 import io.eventuate.EventContext;
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 import org.apache.commons.lang.builder.ToStringBuilder;
 
 import java.util.Optional;

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/SerializedSnapshotWithVersion.java

@@ -1,6 +1,6 @@
 package io.eventuate.javaclient.commonimpl;
 
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 
 public class SerializedSnapshotWithVersion {
 

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/adapters/AsyncToSyncAggregateCrudAdapter.java

@@ -3,7 +3,7 @@
 import io.eventuate.Aggregate;
 import io.eventuate.CompletableFutureUtil;
 import io.eventuate.EntityIdAndType;
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 import io.eventuate.javaclient.commonimpl.*;
 
 import java.util.List;

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/adapters/SyncToAsyncAggregateCrudAdapter.java

@@ -3,7 +3,7 @@
 import io.eventuate.Aggregate;
 import io.eventuate.CompletableFutureUtil;
 import io.eventuate.EntityIdAndType;
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 import io.eventuate.javaclient.commonimpl.AggregateCrudFindOptions;
 import io.eventuate.javaclient.commonimpl.AggregateCrudSaveOptions;
 import io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions;

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/sync/AggregateCrud.java

@@ -2,7 +2,7 @@
 
 import io.eventuate.Aggregate;
 import io.eventuate.EntityIdAndType;
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 import io.eventuate.javaclient.commonimpl.*;
 
 import java.util.List;

eventuate-client-java-common-impl/src/main/java/io/eventuate/javaclient/commonimpl/sync/EventuateAggregateStoreImpl.java

@@ -9,13 +9,14 @@
 import io.eventuate.Event;
 import io.eventuate.EventWithMetadata;
 import io.eventuate.FindOptions;
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 import io.eventuate.MissingApplyEventMethodStrategy;
 import io.eventuate.SaveOptions;
 import io.eventuate.Snapshot;
 import io.eventuate.SnapshotManager;
 import io.eventuate.SubscriberOptions;
 import io.eventuate.UpdateOptions;
+import io.eventuate.common.json.mapper.JSonMapper;
 import io.eventuate.javaclient.commonimpl.*;
 import io.eventuate.sync.EventuateAggregateStore;
 

eventuate-client-java-event-handling/src/main/java/io/eventuate/javaclient/domain/EventHandlerContextImpl.java

@@ -1,6 +1,7 @@
 package io.eventuate.javaclient.domain;
 
 import io.eventuate.*;
+import io.eventuate.common.id.Int128;
 
 import java.util.Map;
 import java.util.Optional;

eventuate-client-java-event-handling/src/test/java/io/eventuate/javaclient/domain/EventDispatcherTest.java

@@ -1,6 +1,7 @@
 package io.eventuate.javaclient.domain;
 
 import io.eventuate.*;
+import io.eventuate.common.id.Int128;
 import io.eventuate.javaclient.eventhandling.exceptionhandling.EventDeliveryExceptionHandlerManager;
 import io.eventuate.javaclient.eventhandling.exceptionhandling.EventDeliveryExceptionHandlerWithState;
 import io.eventuate.javaclient.eventhandling.exceptionhandling.MyException;

eventuate-client-java-http-stomp/src/main/java/io/eventuate/javaclient/restclient/CreateEntityResponse.java

@@ -1,6 +1,6 @@
 package io.eventuate.javaclient.restclient;
 
-import io.eventuate.Int128;
+import io.eventuate.common.id.Int128;
 
 import java.util.List;