Base package for Axon Server Connector module changed to io.axoniq.ax…

…onserver.connector.
AxonFramework · Sep 10, 2018 · fd487ec · fd487ec
1 parent f17ca3d
commit fd487ec
Show file tree

Hide file tree

Showing 90 changed files with 213 additions and 213 deletions.
diff --git a/...onhub/client/AxonServerConfiguration.java → ...er/connector/AxonServerConfiguration.java b/...onhub/client/AxonServerConfiguration.java → ...er/connector/AxonServerConfiguration.java
@@ -13,9 +13,9 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client;
+package io.axoniq.axonserver.connector;
 
-import io.axoniq.axonhub.client.event.util.EventCipher;
+import io.axoniq.axonserver.connector.event.util.EventCipher;
 import io.axoniq.platform.grpc.NodeInfo;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 

diff --git a/...q/axonhub/client/AxonServerException.java → ...server/connector/AxonServerException.java b/...q/axonhub/client/AxonServerException.java → ...server/connector/AxonServerException.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client;
+package io.axoniq.axonserver.connector;
 
 /**
  * Created by Sara Pellegrini on 15/05/2018.

diff --git a/.../axonhub/client/DispatchInterceptors.java → ...erver/connector/DispatchInterceptors.java b/.../axonhub/client/DispatchInterceptors.java → ...erver/connector/DispatchInterceptors.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client;
+package io.axoniq.axonserver.connector;
 
 import org.axonframework.common.Registration;
 import org.axonframework.messaging.Message;

diff --git a/...a/io/axoniq/axonhub/client/ErrorCode.java → ...xoniq/axonserver/connector/ErrorCode.java b/...a/io/axoniq/axonhub/client/ErrorCode.java → ...xoniq/axonserver/connector/ErrorCode.java
@@ -13,9 +13,9 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client;
+package io.axoniq.axonserver.connector;
 
-import io.axoniq.axonhub.client.event.util.EventStoreClientException;
+import io.axoniq.axonserver.connector.event.util.EventStoreClientException;
 import org.axonframework.commandhandling.model.AggregateRolledBackException;
 import org.axonframework.commandhandling.model.ConcurrencyException;
 import org.axonframework.common.AxonException;

diff --git a/...hub/client/PlatformConnectionManager.java → .../connector/PlatformConnectionManager.java b/...hub/client/PlatformConnectionManager.java → .../connector/PlatformConnectionManager.java
@@ -13,10 +13,10 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client;
+package io.axoniq.axonserver.connector;
 
-import io.axoniq.axonhub.client.util.ContextAddingInterceptor;
-import io.axoniq.axonhub.client.util.TokenAddingInterceptor;
+import io.axoniq.axonserver.connector.util.ContextAddingInterceptor;
+import io.axoniq.axonserver.connector.util.TokenAddingInterceptor;
 import io.axoniq.axonhub.grpc.CommandProviderInbound;
 import io.axoniq.axonhub.grpc.CommandProviderOutbound;
 import io.axoniq.axonhub.grpc.CommandServiceGrpc;

diff --git a/...a/io/axoniq/axonhub/client/Publisher.java → ...xoniq/axonserver/connector/Publisher.java b/...a/io/axoniq/axonhub/client/Publisher.java → ...xoniq/axonserver/connector/Publisher.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client;
+package io.axoniq.axonserver.connector;
 
 /**
  * Created by Sara Pellegrini on 11/05/2018.

diff --git a/...ub/client/SynchronizedStreamObserver.java → ...connector/SynchronizedStreamObserver.java b/...ub/client/SynchronizedStreamObserver.java → ...connector/SynchronizedStreamObserver.java
@@ -1,4 +1,4 @@
-package io.axoniq.axonhub.client;
+package io.axoniq.axonserver.connector;
 
 import io.grpc.stub.StreamObserver;
 

diff --git a/.../client/command/AxonServerCommandBus.java → ...nnector/command/AxonServerCommandBus.java b/.../client/command/AxonServerCommandBus.java → ...nnector/command/AxonServerCommandBus.java
@@ -13,19 +13,19 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.command;
+package io.axoniq.axonserver.connector.command;
 
 import io.axoniq.axonhub.Command;
 import io.axoniq.axonhub.CommandResponse;
 import io.axoniq.axonhub.CommandSubscription;
-import io.axoniq.axonhub.client.AxonServerConfiguration;
-import io.axoniq.axonhub.client.DispatchInterceptors;
-import io.axoniq.axonhub.client.ErrorCode;
-import io.axoniq.axonhub.client.PlatformConnectionManager;
-import io.axoniq.axonhub.client.util.ContextAddingInterceptor;
-import io.axoniq.axonhub.client.util.ExceptionSerializer;
-import io.axoniq.axonhub.client.util.FlowControllingStreamObserver;
-import io.axoniq.axonhub.client.util.TokenAddingInterceptor;
+import io.axoniq.axonserver.connector.AxonServerConfiguration;
+import io.axoniq.axonserver.connector.DispatchInterceptors;
+import io.axoniq.axonserver.connector.ErrorCode;
+import io.axoniq.axonserver.connector.PlatformConnectionManager;
+import io.axoniq.axonserver.connector.util.ContextAddingInterceptor;
+import io.axoniq.axonserver.connector.util.ExceptionSerializer;
+import io.axoniq.axonserver.connector.util.FlowControllingStreamObserver;
+import io.axoniq.axonserver.connector.util.TokenAddingInterceptor;
 import io.axoniq.axonhub.grpc.CommandProviderInbound;
 import io.axoniq.axonhub.grpc.CommandProviderOutbound;
 import io.axoniq.axonhub.grpc.CommandServiceGrpc;
@@ -53,7 +53,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.stream.IntStream;
 
-import static io.axoniq.axonhub.client.util.ProcessingInstructionHelper.priority;
+import static io.axoniq.axonserver.connector.util.ProcessingInstructionHelper.priority;
 
 
 /**

diff --git a/...lient/command/AxonServerRegistration.java → ...ector/command/AxonServerRegistration.java b/...lient/command/AxonServerRegistration.java → ...ector/command/AxonServerRegistration.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.command;
+package io.axoniq.axonserver.connector.command;
 
 import org.axonframework.common.Registration;
 

diff --git a/...nt/command/CommandPriorityCalculator.java → ...or/command/CommandPriorityCalculator.java b/...nt/command/CommandPriorityCalculator.java → ...or/command/CommandPriorityCalculator.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.command;
+package io.axoniq.axonserver.connector.command;
 
 import org.axonframework.commandhandling.CommandMessage;
 /**

diff --git a/...hub/client/command/CommandSerializer.java → .../connector/command/CommandSerializer.java b/...hub/client/command/CommandSerializer.java → .../connector/command/CommandSerializer.java
@@ -13,18 +13,18 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.command;
+package io.axoniq.axonserver.connector.command;
 
 import io.axoniq.axonhub.Command;
 import io.axoniq.axonhub.CommandResponse;
 import io.axoniq.axonhub.ProcessingInstruction;
 import io.axoniq.axonhub.ProcessingKey;
-import io.axoniq.axonhub.client.AxonServerConfiguration;
-import io.axoniq.axonhub.client.util.GrpcMetaDataConverter;
-import io.axoniq.axonhub.client.util.GrpcMetadataSerializer;
-import io.axoniq.axonhub.client.util.GrpcObjectSerializer;
-import io.axoniq.axonhub.client.util.GrpcPayloadSerializer;
-import io.axoniq.axonhub.client.util.GrpcSerializedObject;
+import io.axoniq.axonserver.connector.AxonServerConfiguration;
+import io.axoniq.axonserver.connector.util.GrpcMetaDataConverter;
+import io.axoniq.axonserver.connector.util.GrpcMetadataSerializer;
+import io.axoniq.axonserver.connector.util.GrpcObjectSerializer;
+import io.axoniq.axonserver.connector.util.GrpcPayloadSerializer;
+import io.axoniq.axonserver.connector.util.GrpcSerializedObject;
 import io.axoniq.axonhub.grpc.CommandProviderOutbound;
 import io.axoniq.platform.MetaDataValue;
 import org.axonframework.commandhandling.CommandMessage;

diff --git a/...ent/command/GrpcBackedCommandMessage.java → ...tor/command/GrpcBackedCommandMessage.java b/...ent/command/GrpcBackedCommandMessage.java → ...tor/command/GrpcBackedCommandMessage.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.command;
+package io.axoniq.axonserver.connector.command;
 
 import io.axoniq.axonhub.Command;
 import io.axoniq.platform.MetaDataValue;

diff --git a/...lient/command/RemoteCommandException.java → ...ector/command/RemoteCommandException.java b/...lient/command/RemoteCommandException.java → ...ector/command/RemoteCommandException.java
@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.axoniq.axonhub.client.command;
+package io.axoniq.axonserver.connector.command;
 
 import io.axoniq.axonhub.ErrorMessage;
 

diff --git a/.../client/event/AppendEventTransaction.java → ...nnector/event/AppendEventTransaction.java b/.../client/event/AppendEventTransaction.java → ...nnector/event/AppendEventTransaction.java
@@ -13,11 +13,11 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event;
+package io.axoniq.axonserver.connector.event;
 
 import io.axoniq.axondb.Event;
 import io.axoniq.axondb.grpc.Confirmation;
-import io.axoniq.axonhub.client.event.util.EventCipher;
+import io.axoniq.axonserver.connector.event.util.EventCipher;
 import io.grpc.stub.StreamObserver;
 
 import java.util.concurrent.CompletableFuture;

diff --git a/...iq/axonhub/client/event/AxonDBClient.java → ...nserver/connector/event/AxonDBClient.java b/...iq/axonhub/client/event/AxonDBClient.java → ...nserver/connector/event/AxonDBClient.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event;
+package io.axoniq.axonserver.connector.event;
 
 import io.axoniq.axondb.Event;
 import io.axoniq.axondb.grpc.Confirmation;
@@ -29,13 +29,13 @@
 import io.axoniq.axondb.grpc.ReadHighestSequenceNrRequest;
 import io.axoniq.axondb.grpc.ReadHighestSequenceNrResponse;
 import io.axoniq.axondb.grpc.TrackingToken;
-import io.axoniq.axonhub.client.AxonServerConfiguration;
-import io.axoniq.axonhub.client.AxonServerException;
-import io.axoniq.axonhub.client.PlatformConnectionManager;
-import io.axoniq.axonhub.client.event.util.EventCipher;
-import io.axoniq.axonhub.client.event.util.GrpcExceptionParser;
-import io.axoniq.axonhub.client.util.ContextAddingInterceptor;
-import io.axoniq.axonhub.client.util.TokenAddingInterceptor;
+import io.axoniq.axonserver.connector.AxonServerConfiguration;
+import io.axoniq.axonserver.connector.AxonServerException;
+import io.axoniq.axonserver.connector.PlatformConnectionManager;
+import io.axoniq.axonserver.connector.event.util.EventCipher;
+import io.axoniq.axonserver.connector.event.util.GrpcExceptionParser;
+import io.axoniq.axonserver.connector.util.ContextAddingInterceptor;
+import io.axoniq.axonserver.connector.util.TokenAddingInterceptor;
 import io.grpc.Channel;
 import io.grpc.Status;
 import io.grpc.StatusRuntimeException;

diff --git a/...ient/event/ClientConnectionException.java → ...ctor/event/ClientConnectionException.java b/...ient/event/ClientConnectionException.java → ...ctor/event/ClientConnectionException.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event;
+package io.axoniq.axonserver.connector.event;
 
 /**
  * Exception describing an error reported by the AxonIQ Event Store Client.

diff --git a/...ient/event/axon/AxonServerEventStore.java → ...ctor/event/axon/AxonServerEventStore.java b/...ient/event/axon/AxonServerEventStore.java → ...ctor/event/axon/AxonServerEventStore.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event.axon;
+package io.axoniq.axonserver.connector.event.axon;
 
 import com.google.protobuf.ByteString;
 import io.axoniq.axondb.Event;
@@ -23,13 +23,13 @@
 import io.axoniq.axondb.grpc.QueryEventsRequest;
 import io.axoniq.axondb.grpc.QueryEventsResponse;
 import io.axoniq.axondb.grpc.ReadHighestSequenceNrResponse;
-import io.axoniq.axonhub.client.AxonServerConfiguration;
-import io.axoniq.axonhub.client.ErrorCode;
-import io.axoniq.axonhub.client.PlatformConnectionManager;
-import io.axoniq.axonhub.client.event.AppendEventTransaction;
-import io.axoniq.axonhub.client.event.AxonDBClient;
-import io.axoniq.axonhub.client.util.FlowControllingStreamObserver;
-import io.axoniq.axonhub.client.util.GrpcMetaDataConverter;
+import io.axoniq.axonserver.connector.AxonServerConfiguration;
+import io.axoniq.axonserver.connector.ErrorCode;
+import io.axoniq.axonserver.connector.PlatformConnectionManager;
+import io.axoniq.axonserver.connector.event.AppendEventTransaction;
+import io.axoniq.axonserver.connector.event.AxonDBClient;
+import io.axoniq.axonserver.connector.util.FlowControllingStreamObserver;
+import io.axoniq.axonserver.connector.util.GrpcMetaDataConverter;
 import io.grpc.stub.StreamObserver;
 import org.axonframework.common.Assert;
 import org.axonframework.eventhandling.EventMessage;

diff --git a/...xonhub/client/event/axon/EventBuffer.java → ...ver/connector/event/axon/EventBuffer.java b/...xonhub/client/event/axon/EventBuffer.java → ...ver/connector/event/axon/EventBuffer.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event.axon;
+package io.axoniq.axonserver.connector.event.axon;
 
 import io.axoniq.axondb.grpc.EventWithToken;
 import org.axonframework.eventhandling.TrackedEventMessage;

diff --git a/...axon/EventProcessorInfoConfiguration.java → ...axon/EventProcessorInfoConfiguration.java b/...axon/EventProcessorInfoConfiguration.java → ...axon/EventProcessorInfoConfiguration.java
@@ -13,14 +13,14 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event.axon;
+package io.axoniq.axonserver.connector.event.axon;
 
-import io.axoniq.axonhub.client.AxonServerConfiguration;
-import io.axoniq.axonhub.client.PlatformConnectionManager;
-import io.axoniq.axonhub.client.processor.EventProcessorControlService;
-import io.axoniq.axonhub.client.processor.EventProcessorController;
-import io.axoniq.axonhub.client.processor.grpc.GrpcEventProcessorInfoSource;
-import io.axoniq.axonhub.client.processor.schedule.ScheduledEventProcessorInfoSource;
+import io.axoniq.axonserver.connector.AxonServerConfiguration;
+import io.axoniq.axonserver.connector.PlatformConnectionManager;
+import io.axoniq.axonserver.connector.processor.EventProcessorControlService;
+import io.axoniq.axonserver.connector.processor.EventProcessorController;
+import io.axoniq.axonserver.connector.processor.grpc.GrpcEventProcessorInfoSource;
+import io.axoniq.axonserver.connector.processor.schedule.ScheduledEventProcessorInfoSource;
 import org.axonframework.config.Configuration;
 import org.axonframework.config.EventHandlingConfiguration;
 import org.axonframework.config.ModuleConfiguration;

diff --git a/...event/axon/GrpcBackedDomainEventData.java → ...event/axon/GrpcBackedDomainEventData.java b/...event/axon/GrpcBackedDomainEventData.java → ...event/axon/GrpcBackedDomainEventData.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event.axon;
+package io.axoniq.axonserver.connector.event.axon;
 
 import io.axoniq.axondb.Event;
 import org.axonframework.eventsourcing.eventstore.DomainEventData;

diff --git a/...ent/axon/GrpcMetaDataAwareSerializer.java → ...ent/axon/GrpcMetaDataAwareSerializer.java b/...ent/axon/GrpcMetaDataAwareSerializer.java → ...ent/axon/GrpcMetaDataAwareSerializer.java
@@ -12,9 +12,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.axoniq.axonhub.client.event.axon;
+package io.axoniq.axonserver.connector.event.axon;
 
-import io.axoniq.axonhub.client.util.GrpcMetaDataConverter;
+import io.axoniq.axonserver.connector.util.GrpcMetaDataConverter;
 import io.axoniq.platform.MetaDataValue;
 import org.axonframework.serialization.Converter;
 import org.axonframework.serialization.SerializedObject;

diff --git a/...xonhub/client/event/axon/QueryResult.java → ...ver/connector/event/axon/QueryResult.java b/...xonhub/client/event/axon/QueryResult.java → ...ver/connector/event/axon/QueryResult.java
@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.axoniq.axonhub.client.event.axon;
+package io.axoniq.axonserver.connector.event.axon;
 
 import io.axoniq.axondb.QueryValue;
 import io.axoniq.axondb.grpc.RowResponse;

diff --git a/.../client/event/axon/QueryResultBuffer.java → ...nnector/event/axon/QueryResultBuffer.java b/.../client/event/axon/QueryResultBuffer.java → ...nnector/event/axon/QueryResultBuffer.java
@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.axoniq.axonhub.client.event.axon;
+package io.axoniq.axonserver.connector.event.axon;
 
 import io.axoniq.axondb.grpc.QueryEventsResponse;
 import io.axoniq.axondb.grpc.RowResponse;

diff --git a/.../client/event/axon/QueryResultStream.java → ...nnector/event/axon/QueryResultStream.java b/.../client/event/axon/QueryResultStream.java → ...nnector/event/axon/QueryResultStream.java
@@ -12,7 +12,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.axoniq.axonhub.client.event.axon;
+package io.axoniq.axonserver.connector.event.axon;
 
 import java.util.Iterator;
 import java.util.concurrent.TimeUnit;

diff --git a/...xonhub/client/event/util/EventCipher.java → ...ver/connector/event/util/EventCipher.java b/...xonhub/client/event/util/EventCipher.java → ...ver/connector/event/util/EventCipher.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event.util;
+package io.axoniq.axonserver.connector.event.util;
 
 import com.google.protobuf.ByteString;
 import io.axoniq.axondb.Event;

diff --git a/...event/util/EventStoreClientException.java → ...event/util/EventStoreClientException.java b/...event/util/EventStoreClientException.java → ...event/util/EventStoreClientException.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event.util;
+package io.axoniq.axonserver.connector.event.util;
 
 /**
  *

diff --git a/...lient/event/util/GrpcExceptionParser.java → ...ector/event/util/GrpcExceptionParser.java b/...lient/event/util/GrpcExceptionParser.java → ...ector/event/util/GrpcExceptionParser.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.event.util;
+package io.axoniq.axonserver.connector.event.util;
 
 import io.grpc.Metadata;
 import io.grpc.Status;

diff --git a/...ocessor/EventProcessorControlService.java → ...ocessor/EventProcessorControlService.java b/...ocessor/EventProcessorControlService.java → ...ocessor/EventProcessorControlService.java
@@ -13,11 +13,11 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.processor;
+package io.axoniq.axonserver.connector.processor;
 
-import io.axoniq.axonhub.client.PlatformConnectionManager;
-import io.axoniq.axonhub.client.processor.grpc.GrpcEventProcessorMapping;
-import io.axoniq.axonhub.client.processor.grpc.PlatformInboundMessage;
+import io.axoniq.axonserver.connector.PlatformConnectionManager;
+import io.axoniq.axonserver.connector.processor.grpc.GrpcEventProcessorMapping;
+import io.axoniq.axonserver.connector.processor.grpc.PlatformInboundMessage;
 import io.axoniq.platform.grpc.PauseEventProcessor;
 import io.axoniq.platform.grpc.PlatformOutboundInstruction;
 import io.axoniq.platform.grpc.ReleaseEventProcessorSegment;

diff --git a/...t/processor/EventProcessorController.java → ...r/processor/EventProcessorController.java b/...t/processor/EventProcessorController.java → ...r/processor/EventProcessorController.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.processor;
+package io.axoniq.axonserver.connector.processor;
 
 import org.axonframework.config.EventHandlingConfiguration;
 import org.axonframework.eventhandling.EventProcessor;

diff --git a/...t/processor/EventProcessorInfoSource.java → ...r/processor/EventProcessorInfoSource.java b/...t/processor/EventProcessorInfoSource.java → ...r/processor/EventProcessorInfoSource.java
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.axonhub.client.processor;
+package io.axoniq.axonserver.connector.processor;
 
 /**
  * Created by Sara Pellegrini on 09/03/2018.