|
14 | 14 | import org.reactivecommons.async.rabbit.communications.ReactiveMessageListener; |
15 | 15 | import org.reactivecommons.async.rabbit.communications.ReactiveMessageSender; |
16 | 16 | import org.reactivecommons.async.rabbit.communications.TopologyCreator; |
17 | | -import org.reactivecommons.async.rabbit.communications.UnroutableMessageHandler; |
18 | 17 | import org.reactivecommons.async.rabbit.communications.UnroutableMessageNotifier; |
19 | 18 | import org.reactivecommons.async.rabbit.config.ConnectionFactoryProvider; |
20 | 19 | import org.reactivecommons.async.rabbit.config.RabbitProperties; |
@@ -100,7 +99,8 @@ public static ReactiveMessageSender createMessageSender(ConnectionFactoryProvide |
100 | 99 | UnroutableMessageNotifier unroutableMessageNotifier) { |
101 | 100 | final Sender sender = RabbitFlux.createSender(reactiveCommonsSenderOptions(props.getAppName(), provider, |
102 | 101 | props.getConnectionProperties())); |
103 | | - return new ReactiveMessageSender(sender, props.getAppName(), converter, new TopologyCreator(sender, props.getQueueType()), |
| 102 | + return new ReactiveMessageSender(sender, props.getAppName(), converter, new TopologyCreator(sender, |
| 103 | + props.getQueueType()), |
104 | 104 | props.getMandatory(), unroutableMessageNotifier |
105 | 105 | ); |
106 | 106 | } |
@@ -155,7 +155,7 @@ private static SenderOptions reactiveCommonsSenderOptions(String appName, Connec |
155 | 155 |
|
156 | 156 | private static Mono<Connection> createConnectionMono(ConnectionFactory factory, String connectionPrefix, |
157 | 157 | String connectionType) { |
158 | | - System.out.println("Creating connection mono to RabbitMQ Broker in host '" + factory.getHost() + "' with " + |
| 158 | + log.info("Creating connection mono to RabbitMQ Broker in host '" + factory.getHost() + "' with " + |
159 | 159 | "type: " + connectionType); |
160 | 160 | return Mono.fromCallable(() -> factory.newConnection(connectionPrefix + " " + connectionType)) |
161 | 161 | .doOnError(err -> |
|
0 commit comments