Skip to content

Commit e9e0fb8

Browse files
committed
update health for eda, append default app props
1 parent 1518551 commit e9e0fb8

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import io.micrometer.core.instrument.MeterRegistry;
44
import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
55
import lombok.RequiredArgsConstructor;
6+
import org.reactivecommons.async.RabbitEDADirectAsyncGateway;
67
import org.reactivecommons.async.commons.config.BrokerConfig;
78
import org.reactivecommons.async.commons.converters.MessageConverter;
89
import org.reactivecommons.async.commons.reply.ReactiveReplyRouter;
@@ -25,7 +26,7 @@ public class DirectAsyncGatewayConfig {
2526

2627
@Bean
2728
public RabbitDirectAsyncGateway rabbitDirectAsyncGateway(BrokerConfig config, ReactiveReplyRouter router, ConnectionManager manager, MessageConverter converter, MeterRegistry meterRegistry) throws Exception {
28-
return new RabbitDirectAsyncGateway(config, router, manager.getSender(DEFAULT_DOMAIN), props.getDirectMessagesExchangeName(), converter, meterRegistry);
29+
return new RabbitEDADirectAsyncGateway(config, router, manager, props.getDirectMessagesExchangeName(), converter, meterRegistry);
2930
}
3031

3132
@Bean

0 commit comments

Comments
 (0)