@@ -90,8 +90,10 @@ public static DiscardNotifier createDiscardNotifier(ReactiveMessageSender sender
90
90
return new DLQDiscardNotifier (appDomainEventBus , converter );
91
91
}
92
92
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 );
95
97
final ChannelPoolOptions channelPoolOptions = new ChannelPoolOptions ();
96
98
final PropertyMapper map = PropertyMapper .get ();
97
99
@@ -109,10 +111,12 @@ private static SenderOptions reactiveCommonsSenderOptions(String appName, Connec
109
111
.transform (Utils ::cache ));
110
112
}
111
113
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 ) {
113
116
return Mono .fromCallable (() -> factory .newConnection (connectionPrefix + " " + connectionType ))
114
117
.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 )
116
120
)
117
121
.retryWhen (Retry .backoff (Long .MAX_VALUE , Duration .ofMillis (300 ))
118
122
.maxBackoff (Duration .ofMillis (3000 )))
0 commit comments