File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -35,6 +35,9 @@ public class RabbitMqConfig {
3535 @ Value ("${app.async.flux.maxConcurrency:250}" )
3636 private Integer maxConcurrency ;
3737
38+ @ Value ("${spring.application.name}" )
39+ private String appName ;
40+
3841 @ Bean
3942 public ReactiveMessageSender messageSender (ConnectionFactoryProvider provider , MessageConverter converter ,
4043 BrokerConfigProps brokerConfigProps , RabbitProperties rabbitProperties ) {
@@ -93,7 +96,7 @@ public MessageConverter messageConverter(ObjectMapperSupplier objectMapperSuppli
9396
9497 Mono <Connection > createSenderConnectionMono (ConnectionFactory factory , String name ) {
9598 final Scheduler senderScheduler = Schedulers .elastic ();
96- return Mono .fromCallable (() -> factory .newConnection (name ))
99+ return Mono .fromCallable (() -> factory .newConnection (appName + " " + name ))
97100 .doOnError (err ->
98101 log .log (Level .SEVERE , "Error creating connection to RabbitMq Broker. Starting retry process..." , err )
99102 )
You can’t perform that action at this time.
0 commit comments