Skip to content

Commit

Permalink
reorganized modules.
Browse files Browse the repository at this point in the history
  • Loading branch information
dartartem committed Feb 27, 2020
1 parent 4afdfd4 commit a6ecb61
Show file tree
Hide file tree
Showing 107 changed files with 185 additions and 182 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@ apply plugin: PrivateModulePlugin

dependencies {
compile project(":eventuate-tram-producer-jdbc")
compile project(":eventuate-tram-consumer-jdbc-spring")
compile project(":eventuate-tram-spring-consumer-jdbc")
compile project(":eventuate-tram-integration-test-common")
compile project(":eventuate-tram-commands-spring")
compile project(":eventuate-tram-spring-commands")

testCompile "io.eventuate.cdc:eventuate-local-java-test-util:$eventuateCdcVersion"
testCompile "org.springframework.boot:spring-boot-starter-test:$springBootCdcVersion"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@

import io.eventuate.tram.commands.consumer.CommandDispatcher;
import io.eventuate.tram.commands.consumer.CommandDispatcherFactory;
import io.eventuate.tram.commands.spring.consumer.TramCommandConsumerConfiguration;
import io.eventuate.tram.commands.spring.producer.TramCommandProducerConfiguration;
import io.eventuate.tram.consumer.common.spring.TramNoopDuplicateMessageDetectorConfiguration;
import io.eventuate.tram.spring.commands.consumer.TramCommandConsumerConfiguration;
import io.eventuate.tram.spring.commands.producer.TramCommandProducerConfiguration;
import io.eventuate.tram.spring.consumer.common.TramNoopDuplicateMessageDetectorConfiguration;
import io.eventuate.tram.integrationtest.common.TramIntegrationTestMySqlBinlogKafkaConfiguration;
import io.eventuate.tram.integrationtest.common.TramIntegrationTestMySqlBinlogRedisConfiguration;
import io.eventuate.tram.integrationtest.common.TramIntegrationTestPollingActiveMQConfiguration;
Expand Down
2 changes: 1 addition & 1 deletion eventuate-tram-consumer-activemq/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ apply plugin: PublicModulePlugin

dependencies {
compile project(":eventuate-tram-messaging")
compile project(":eventuate-tram-consumer-common-spring")
compile project(":eventuate-tram-spring-consumer-common")

compile "io.eventuate.messaging.activemq:eventuate-messaging-activemq-consumer:$eventuateMessagingActiveMQVersion"
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import io.eventuate.messaging.activemq.consumer.MessageConsumerActiveMQConfiguration;
import io.eventuate.messaging.activemq.consumer.MessageConsumerActiveMQImpl;
import io.eventuate.tram.consumer.common.MessageConsumerImplementation;
import io.eventuate.tram.consumer.common.spring.TramConsumerCommonConfiguration;
import io.eventuate.tram.spring.consumer.common.TramConsumerCommonConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
Expand Down
2 changes: 1 addition & 1 deletion eventuate-tram-consumer-rabbitmq/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ apply plugin: PublicModulePlugin

dependencies {
compile project(":eventuate-tram-messaging")
compile project(":eventuate-tram-consumer-common-spring")
compile project(":eventuate-tram-spring-consumer-common")

compile "io.eventuate.messaging.rabbitmq:eventuate-messaging-rabbitmq-consumer:$eventuateMessagingRabbitMQVersion"
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import io.eventuate.messaging.rabbitmq.consumer.MessageConsumerRabbitMQConfiguration;
import io.eventuate.messaging.rabbitmq.consumer.MessageConsumerRabbitMQImpl;
import io.eventuate.tram.consumer.common.MessageConsumerImplementation;
import io.eventuate.tram.consumer.common.spring.TramConsumerCommonConfiguration;
import io.eventuate.tram.spring.consumer.common.TramConsumerCommonConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
Expand Down
2 changes: 1 addition & 1 deletion eventuate-tram-consumer-redis/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ apply plugin: PublicModulePlugin

dependencies {
compile project(":eventuate-tram-messaging")
compile project(":eventuate-tram-consumer-common-spring")
compile project(":eventuate-tram-spring-consumer-common")

compile "io.eventuate.messaging.redis:eventuate-messaging-redis-consumer:$eventuateMessagingRedisVersion"
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import io.eventuate.messaging.redis.consumer.MessageConsumerRedisConfiguration;
import io.eventuate.messaging.redis.consumer.MessageConsumerRedisImpl;
import io.eventuate.tram.consumer.common.MessageConsumerImplementation;
import io.eventuate.tram.consumer.common.spring.TramConsumerCommonConfiguration;
import io.eventuate.tram.spring.consumer.common.TramConsumerCommonConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
Expand Down
2 changes: 1 addition & 1 deletion eventuate-tram-db-broker-integration-test/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ apply plugin: PublicModulePlugin

dependencies {
compile project(":eventuate-tram-integration-test-common")
compile project(":eventuate-tram-messaging-spring")
compile project(":eventuate-tram-spring-messaging")
testCompile "org.springframework.boot:spring-boot-starter-test:$springBootCdcVersion"
testCompile "io.eventuate.cdc:eventuate-local-java-test-util:$eventuateCdcVersion"
testCompile "io.eventuate.util:eventuate-util-test:$eventuateUtilVersion"
Expand Down
16 changes: 0 additions & 16 deletions eventuate-tram-in-memory-spring/build.gradle

This file was deleted.

4 changes: 2 additions & 2 deletions eventuate-tram-in-memory/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@ apply plugin: PublicModulePlugin

dependencies {
compile project(":eventuate-tram-messaging")
compile project(":eventuate-tram-consumer-common-spring")
compile project(":eventuate-tram-messaging-producer-common-spring")
compile project(":eventuate-tram-spring-consumer-common")
compile project(":eventuate-tram-spring-messaging-producer-common")

compile project(":eventuate-tram-consumer-jdbc")

Expand Down
2 changes: 1 addition & 1 deletion eventuate-tram-integration-test-common/build.gradle
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
apply plugin: PublicModulePlugin

dependencies {
compile project(":eventuate-tram-jdbc-kafka-spring")
compile project(":eventuate-tram-spring-jdbc-kafka")
compile project(":eventuate-tram-jdbc-rabbitmq")
compile project(":eventuate-tram-jdbc-activemq")
compile project(":eventuate-tram-jdbc-redis")
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package io.eventuate.tram.integrationtest.common;

import io.eventuate.tram.jdbckafka.TramJdbcKafkaConfiguration;
import io.eventuate.tram.spring.jdbckafka.TramJdbcKafkaConfiguration;
import org.springframework.context.annotation.Conditional;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
Expand Down
6 changes: 3 additions & 3 deletions eventuate-tram-jdbc-activemq/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@ apply plugin: PublicModulePlugin

dependencies {

compile project(":eventuate-tram-consumer-common-spring")
compile project(":eventuate-tram-producer-jdbc-spring")
compile project(":eventuate-tram-consumer-jdbc-spring")
compile project(":eventuate-tram-spring-consumer-common")
compile project(":eventuate-tram-spring-producer-jdbc")
compile project(":eventuate-tram-spring-consumer-jdbc")
compile project(":eventuate-tram-consumer-activemq")

compile "io.eventuate.messaging.activemq:eventuate-messaging-activemq-consumer:$eventuateMessagingActiveMQVersion"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.eventuate.tram.jdbcactivemq;

import io.eventuate.tram.consumer.activemq.EventuateTramActiveMQMessageConsumerConfiguration;
import io.eventuate.tram.messaging.producer.jdbc.spring.TramMessageProducerJdbcConfiguration;
import io.eventuate.tram.spring.messaging.producer.jdbc.TramMessageProducerJdbcConfiguration;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;

Expand Down
10 changes: 0 additions & 10 deletions eventuate-tram-jdbc-kafka-spring/build.gradle

This file was deleted.

6 changes: 3 additions & 3 deletions eventuate-tram-jdbc-rabbitmq/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@ apply plugin: PublicModulePlugin
dependencies {
compile "io.eventuate.messaging.rabbitmq:eventuate-messaging-rabbitmq-consumer:$eventuateMessagingRabbitMQVersion"

compile project(":eventuate-tram-consumer-common-spring")
compile project(":eventuate-tram-producer-jdbc-spring")
compile project(":eventuate-tram-consumer-jdbc-spring")
compile project(":eventuate-tram-spring-consumer-common")
compile project(":eventuate-tram-spring-producer-jdbc")
compile project(":eventuate-tram-spring-consumer-jdbc")
compile project(":eventuate-tram-consumer-rabbitmq")
}
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.eventuate.tram.jdbcrabbitmq;

import io.eventuate.tram.consumer.rabbitmq.EventuateTramRabbitMQMessageConsumerConfiguration;
import io.eventuate.tram.messaging.producer.jdbc.spring.TramMessageProducerJdbcConfiguration;
import io.eventuate.tram.spring.messaging.producer.jdbc.TramMessageProducerJdbcConfiguration;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;

Expand Down
6 changes: 3 additions & 3 deletions eventuate-tram-jdbc-redis/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@ apply plugin: PublicModulePlugin
dependencies {
compile "io.eventuate.messaging.redis:eventuate-messaging-redis-consumer:$eventuateMessagingRedisVersion"

compile project(":eventuate-tram-consumer-common-spring")
compile project(":eventuate-tram-producer-jdbc-spring")
compile project(":eventuate-tram-consumer-jdbc-spring")
compile project(":eventuate-tram-spring-consumer-common")
compile project(":eventuate-tram-spring-producer-jdbc")
compile project(":eventuate-tram-spring-consumer-jdbc")
compile project(":eventuate-tram-consumer-redis")
}
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.eventuate.tram.jdbcredis;

import io.eventuate.tram.consumer.redis.EventuateTramRedisMessageConsumerConfiguration;
import io.eventuate.tram.messaging.producer.jdbc.spring.TramMessageProducerJdbcConfiguration;
import io.eventuate.tram.spring.messaging.producer.jdbc.TramMessageProducerJdbcConfiguration;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.commands.micronaut;
package io.eventuate.tram.micronaut.commands;

import io.eventuate.tram.commands.consumer.CommandDispatcher;
import io.micronaut.context.annotation.Context;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.commands.micronaut.consumer;
package io.eventuate.tram.micronaut.commands.consumer;

import io.eventuate.tram.commands.consumer.CommandDispatcherFactory;
import io.eventuate.tram.messaging.consumer.MessageConsumer;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.commands.micronaut.producer;
package io.eventuate.tram.micronaut.commands.producer;

import io.eventuate.tram.commands.producer.CommandProducer;
import io.eventuate.tram.commands.producer.CommandProducerImpl;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.consumer.common.micronaut;
package io.eventuate.tram.micronaut.consumer.common;

import io.eventuate.tram.consumer.common.*;
import io.eventuate.tram.messaging.common.MessageInterceptor;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.consumer.common.micronaut;
package io.eventuate.tram.micronaut.consumer.common;

import io.eventuate.tram.consumer.common.DecoratedMessageHandlerFactory;
import io.eventuate.tram.consumer.common.MessageConsumerImpl;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.consumer.common.micronaut;
package io.eventuate.tram.micronaut.consumer.common;

import io.eventuate.tram.consumer.common.DuplicateMessageDetector;
import io.eventuate.tram.consumer.common.NoopDuplicateMessageDetector;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ dependencyManagement {
dependencies {
compile project(":eventuate-tram-consumer-jdbc")
compile "io.micronaut:micronaut-spring"
compile "io.eventuate.common:eventuate-common-jdbc-micronaut-spring:$eventuateCommonVersion"
compile "io.eventuate.common:eventuate-common-micronaut-spring-jdbc:$eventuateCommonVersion"

annotationProcessor "io.micronaut:micronaut-inject-java"
annotationProcessor "io.micronaut:micronaut-validation"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.consumer.jdbc.micronaut;
package io.eventuate.tram.micronaut.consumer.jdbc;

import io.eventuate.common.jdbc.EventuateJdbcStatementExecutor;
import io.eventuate.common.jdbc.EventuateSchema;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.consumer.jdbc.micronaut;
package io.eventuate.tram.micronaut.consumer.jdbc;

import io.eventuate.tram.consumer.common.DuplicateMessageDetector;
import io.eventuate.tram.consumer.jdbc.TransactionalNoopDuplicateMessageDetector;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.consumer.jdbc.micronaut;
package io.eventuate.tram.micronaut.consumer.jdbc;

import io.eventuate.tram.consumer.common.DuplicateMessageDetector;
import io.micronaut.test.annotation.MicronautTest;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,10 @@ dependencyManagement {
}

dependencies {
compile project(":eventuate-tram-messaging-micronaut")
compile project(":eventuate-tram-micronaut-messaging")
compile project(":eventuate-tram-consumer-kafka")
compile project (":eventuate-tram-consumer-common-micronaut")
compile "io.eventuate.messaging.kafka:eventuate-messaging-kafka-consumer-micronaut:$eventuateMessagingKafkaVersion"
compile project (":eventuate-tram-micronaut-consumer-common")
compile "io.eventuate.messaging.kafka:eventuate-messaging-kafka-micronaut-consumer:$eventuateMessagingKafkaVersion"

annotationProcessor "io.micronaut:micronaut-inject-java"
annotationProcessor "io.micronaut:micronaut-validation"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
package io.eventuate.tram.consumer.kafka;
package io.eventuate.tram.micronaut.consumer.kafka;

import io.eventuate.messaging.kafka.consumer.MessageConsumerKafkaImpl;
import io.eventuate.tram.consumer.common.MessageConsumerImplementation;
import io.eventuate.tram.consumer.kafka.EventuateTramKafkaMessageConsumer;
import io.micronaut.context.annotation.Factory;

import javax.inject.Singleton;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.events.micronaut.common;
package io.eventuate.tram.micronaut.events.common;

import io.eventuate.tram.events.common.DefaultDomainEventNameMapping;
import io.eventuate.tram.events.common.DomainEventNameMapping;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.events.micronaut.publisher;
package io.eventuate.tram.micronaut.events.publisher;

import io.eventuate.tram.events.common.DomainEventNameMapping;
import io.eventuate.tram.events.publisher.DomainEventPublisher;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.events.micronaut.subscriber;
package io.eventuate.tram.micronaut.events.subscriber;

import io.eventuate.tram.events.subscriber.DomainEventDispatcher;
import io.micronaut.context.annotation.Context;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.events.micronaut.subscriber;
package io.eventuate.tram.micronaut.events.subscriber;

import io.eventuate.tram.events.common.DomainEventNameMapping;
import io.eventuate.tram.events.subscriber.DomainEventDispatcherFactory;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,12 @@ dependencyManagement {
dependencies {
compile project(":eventuate-tram-in-memory")

compile project(":eventuate-tram-messaging-micronaut")
compile project(":eventuate-tram-consumer-common-micronaut")
compile project(":eventuate-tram-messaging-producer-common-micronaut")
compile project(":eventuate-tram-consumer-jdbc-micronaut")
compile project(":eventuate-tram-micronaut-messaging")
compile project(":eventuate-tram-micronaut-consumer-common")
compile project(":eventuate-tram-micronaut-messaging-producer-common")
compile project(":eventuate-tram-micronaut-consumer-jdbc")

compile "io.eventuate.common:eventuate-common-in-memory-database-micronaut:$eventuateCommonVersion"
compile "io.eventuate.common:eventuate-common-micronaut-in-memory-database:$eventuateCommonVersion"

compile "io.micronaut:micronaut-spring"
annotationProcessor "io.micronaut:micronaut-inject-java"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.inmemory.micronaut;
package io.eventuate.tram.micronaut.inmemory;

import io.eventuate.common.id.IdGenerator;
import io.eventuate.common.id.IdGeneratorImpl;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.inmemory.micronaut;
package io.eventuate.tram.micronaut.inmemory;

import io.eventuate.tram.inmemory.InMemoryMessageConsumer;
import io.eventuate.tram.inmemory.InMemoryMessageProducer;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.messaging.producer.common.micronaut;
package io.eventuate.tram.micronaut.messaging.producer.common;

import io.eventuate.tram.messaging.common.ChannelMapping;
import io.eventuate.tram.messaging.common.MessageInterceptor;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.messaging.common.micronaut;
package io.eventuate.tram.micronaut.messaging.common;

import io.eventuate.tram.messaging.common.ChannelMapping;
import io.eventuate.tram.messaging.common.DefaultChannelMapping;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,11 +17,11 @@ dependencyManagement {
}

dependencies {
compile project(":eventuate-tram-messaging-micronaut")
compile project(":eventuate-tram-micronaut-messaging")
compile project(":eventuate-tram-producer-jdbc")
compile project(":eventuate-tram-messaging-producer-common-micronaut")
compile project(":eventuate-tram-micronaut-messaging-producer-common")

compile "io.eventuate.common:eventuate-common-jdbc-micronaut:$eventuateCommonVersion"
compile "io.eventuate.common:eventuate-common-micronaut-jdbc:$eventuateCommonVersion"

annotationProcessor "io.micronaut:micronaut-inject-java"
annotationProcessor "io.micronaut:micronaut-validation"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package io.eventuate.tram.messaging.producer.jdbc.micronaut;
package io.eventuate.tram.micronaut.messaging.producer.jdbc;

import io.eventuate.common.id.IdGenerator;
import io.eventuate.common.id.IdGeneratorImpl;
Expand Down
9 changes: 0 additions & 9 deletions eventuate-tram-producer-jdbc-spring/build.gradle

This file was deleted.

Loading

0 comments on commit a6ecb61

Please sign in to comment.