start multibroker

Author: juancgalvis

async/async-rabbit-starter-eda/async-commons-rabbit-starter-eda.gradle

@@ -0,0 +1,15 @@
+ext {
+    artifactId = 'async-commons-rabbit-starter'
+    artifactDescription = 'Async Commons Starter'
+}
+
+dependencies {
+    api project(':async-rabbit')
+    compileOnly 'org.springframework.boot:spring-boot-starter'
+    compileOnly 'org.springframework.boot:spring-boot-starter-actuator'
+
+    annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
+
+    testImplementation 'io.projectreactor:reactor-test'
+    testImplementation 'org.springframework.boot:spring-boot-starter-actuator'
+}

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/impl/config/annotations/EnableCommandListeners.java

@@ -0,0 +1,19 @@
+package org.reactivecommons.async.impl.config.annotations;
+
+import org.reactivecommons.async.rabbit.config.CommandListenersConfig;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE})
+@Documented
+@Import(CommandListenersConfig.class)
+@Configuration
+public @interface EnableCommandListeners {
+}
+
+
+

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/impl/config/annotations/EnableDirectAsyncGateway.java

@@ -0,0 +1,19 @@
+package org.reactivecommons.async.impl.config.annotations;
+
+import org.reactivecommons.async.rabbit.config.DirectAsyncGatewayConfig;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE})
+@Documented
+@Import(DirectAsyncGatewayConfig.class)
+@Configuration
+public @interface EnableDirectAsyncGateway {
+}
+
+
+

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/impl/config/annotations/EnableDomainEventBus.java

@@ -0,0 +1,19 @@
+package org.reactivecommons.async.impl.config.annotations;
+
+import org.reactivecommons.async.rabbit.config.EventBusConfig;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE})
+@Documented
+@Import(EventBusConfig.class)
+@Configuration
+public @interface EnableDomainEventBus {
+}
+
+
+

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/impl/config/annotations/EnableEventListeners.java

@@ -0,0 +1,18 @@
+package org.reactivecommons.async.impl.config.annotations;
+
+import org.reactivecommons.async.rabbit.config.EventListenersConfig;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE})
+@Documented
+@Import(EventListenersConfig.class)
+@Configuration
+public @interface EnableEventListeners {
+}
+
+
+

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/impl/config/annotations/EnableMessageListeners.java

@@ -0,0 +1,26 @@
+package org.reactivecommons.async.impl.config.annotations;
+
+import org.reactivecommons.async.rabbit.config.CommandListenersConfig;
+import org.reactivecommons.async.rabbit.config.EventListenersConfig;
+import org.reactivecommons.async.rabbit.config.NotificacionListenersConfig;
+import org.reactivecommons.async.rabbit.config.QueryListenerConfig;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+/**
+ * This annotation enables all messages listeners (Query, Commands, Events). If you want to enable separately, please use
+ * EnableCommandListeners, EnableQueryListeners or EnableEventListeners.
+ *
+ */
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE})
+@Documented
+@Import({CommandListenersConfig.class, QueryListenerConfig.class, EventListenersConfig.class, NotificacionListenersConfig.class})
+@Configuration
+public @interface EnableMessageListeners {
+}
+
+
+

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/impl/config/annotations/EnableNotificationListener.java

@@ -0,0 +1,19 @@
+package org.reactivecommons.async.impl.config.annotations;
+
+import org.reactivecommons.async.rabbit.config.NotificacionListenersConfig;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE})
+@Documented
+@Import(NotificacionListenersConfig.class)
+@Configuration
+public @interface EnableNotificationListener {
+}
+
+
+

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/impl/config/annotations/EnableQueryListeners.java

@@ -0,0 +1,19 @@
+package org.reactivecommons.async.impl.config.annotations;
+
+import org.reactivecommons.async.rabbit.config.QueryListenerConfig;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE})
+@Documented
+@Import(QueryListenerConfig.class)
+@Configuration
+public @interface EnableQueryListeners {
+}
+
+
+

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/CommandListenersConfig.java

@@ -0,0 +1,39 @@
+package org.reactivecommons.async.rabbit.config;
+
+import lombok.RequiredArgsConstructor;
+import org.reactivecommons.async.commons.DiscardNotifier;
+import org.reactivecommons.async.rabbit.HandlerResolver;
+import org.reactivecommons.async.rabbit.communications.ReactiveMessageListener;
+import org.reactivecommons.async.rabbit.config.props.AsyncProps;
+import org.reactivecommons.async.commons.converters.MessageConverter;
+import org.reactivecommons.async.commons.ext.CustomReporter;
+import org.reactivecommons.async.rabbit.listeners.ApplicationCommandListener;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+@Configuration
+@RequiredArgsConstructor
+@Import(RabbitMqConfig.class)
+public class CommandListenersConfig {
+
+    @Value("${spring.application.name}")
+    private String appName;
+
+    private final AsyncProps asyncProps;
+
+    @Bean
+    public ApplicationCommandListener applicationCommandListener(ReactiveMessageListener listener,
+                                                                 HandlerResolver resolver, MessageConverter converter,
+                                                                 DiscardNotifier discardNotifier,
+                                                                 CustomReporter errorReporter) {
+        ApplicationCommandListener commandListener = new ApplicationCommandListener(listener, appName, resolver,
+                asyncProps.getDirect().getExchange(), converter, asyncProps.getWithDLQRetry(), asyncProps.getMaxRetries(),
+                asyncProps.getRetryDelay(), asyncProps.getDirect().getMaxLengthBytes(), discardNotifier, errorReporter);
+
+        commandListener.startListener();
+
+        return commandListener;
+    }
+}

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/DirectAsyncGatewayConfig.java

@@ -0,0 +1,48 @@
+package org.reactivecommons.async.rabbit.config;
+
+import io.micrometer.core.instrument.MeterRegistry;
+import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
+import lombok.RequiredArgsConstructor;
+import org.reactivecommons.async.commons.config.BrokerConfig;
+import org.reactivecommons.async.commons.converters.MessageConverter;
+import org.reactivecommons.async.commons.reply.ReactiveReplyRouter;
+import org.reactivecommons.async.rabbit.RabbitDirectAsyncGateway;
+import org.reactivecommons.async.rabbit.communications.ReactiveMessageListener;
+import org.reactivecommons.async.rabbit.communications.ReactiveMessageSender;
+import org.reactivecommons.async.rabbit.config.props.BrokerConfigProps;
+import org.reactivecommons.async.rabbit.listeners.ApplicationReplyListener;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+@Configuration
+@Import(RabbitMqConfig.class)
+@RequiredArgsConstructor
+public class DirectAsyncGatewayConfig {
+
+    private final BrokerConfigProps props;
+
+    @Bean
+    public RabbitDirectAsyncGateway rabbitDirectAsyncGateway(BrokerConfig config, ReactiveReplyRouter router, ReactiveMessageSender rSender, MessageConverter converter, MeterRegistry meterRegistry) throws Exception {
+        return new RabbitDirectAsyncGateway(config, router, rSender, props.getDirectMessagesExchangeName(), converter, meterRegistry);
+    }
+
+    @Bean
+    public ApplicationReplyListener msgListener(ReactiveReplyRouter router, BrokerConfig config, ReactiveMessageListener listener) {
+        final ApplicationReplyListener replyListener = new ApplicationReplyListener(router, listener, props.getReplyQueue());
+        replyListener.startListening(config.getRoutingKey());
+        return replyListener;
+    }
+
+    @Bean
+    public ReactiveReplyRouter router() {
+        return new ReactiveReplyRouter();
+    }
+
+    @Bean
+    @ConditionalOnMissingBean(MeterRegistry.class)
+    public MeterRegistry defaultRabbitMeterRegistry() {
+        return new SimpleMeterRegistry();
+    }
+}