@@ -90,8 +90,10 @@ public static DiscardNotifier createDiscardNotifier(ReactiveMessageSender sender
9090 return new DLQDiscardNotifier (appDomainEventBus , converter );
9191 }
9292
93- private static SenderOptions reactiveCommonsSenderOptions (String appName , ConnectionFactoryProvider provider , RabbitProperties rabbitProperties ) {
94- final Mono <Connection > senderConnection = createConnectionMono (provider .getConnectionFactory (), appName , SENDER_TYPE );
93+ private static SenderOptions reactiveCommonsSenderOptions (String appName , ConnectionFactoryProvider provider ,
94+ RabbitProperties rabbitProperties ) {
95+ final Mono <Connection > senderConnection = createConnectionMono (provider .getConnectionFactory (), appName ,
96+ SENDER_TYPE );
9597 final ChannelPoolOptions channelPoolOptions = new ChannelPoolOptions ();
9698 final PropertyMapper map = PropertyMapper .get ();
9799
@@ -109,10 +111,12 @@ private static SenderOptions reactiveCommonsSenderOptions(String appName, Connec
109111 .transform (Utils ::cache ));
110112 }
111113
112- private static Mono <Connection > createConnectionMono (ConnectionFactory factory , String connectionPrefix , String connectionType ) {
114+ private static Mono <Connection > createConnectionMono (ConnectionFactory factory , String connectionPrefix ,
115+ String connectionType ) {
113116 return Mono .fromCallable (() -> factory .newConnection (connectionPrefix + " " + connectionType ))
114117 .doOnError (err ->
115- log .log (Level .SEVERE , "Error creating connection to RabbitMq Broker. Starting retry process..." , err )
118+ log .log (Level .SEVERE , "Error creating connection to RabbitMQ Broker in host" +
119+ factory .getHost () + ". Starting retry process..." , err )
116120 )
117121 .retryWhen (Retry .backoff (Long .MAX_VALUE , Duration .ofMillis (300 ))
118122 .maxBackoff (Duration .ofMillis (3000 )))
0 commit comments