fix: cache resource channel mono

juanmarin-co · juanmarin-co · commit f61b8ecab1be · 2020-04-23T10:00:10.000-05:00
diff --git a/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/RabbitMqConfig.java b/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/RabbitMqConfig.java
@@ -70,7 +70,8 @@ public ReactiveMessageSender messageSender(ConnectionFactoryProvider provider, M
 
         final Sender sender = RabbitFlux.createSender(new SenderOptions()
                 .channelPool(channelPool)
-                .resourceManagementChannelMono(channelPool.getChannelMono()));
+                .resourceManagementChannelMono(channelPool.getChannelMono()
+                        .transform(Utils::cache)));
 
         return new ReactiveMessageSender(sender, brokerConfigProps.getAppName(), converter, new TopologyCreator(sender));
     }
diff --git a/gradle.properties b/gradle.properties
@@ -1,3 +1,3 @@
-version=0.4.5
+version=0.4.6
 springBootVersion=2.2.6.RELEASE
 gradleVersionsVersion=0.28.0

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,8 @@ public ReactiveMessageSender messageSender(ConnectionFactoryProvider provider, M`
`70`	`70`
`71`	`71`	`final Sender sender = RabbitFlux.createSender(new SenderOptions()`
`72`	`72`	`.channelPool(channelPool)`
`73`		`- .resourceManagementChannelMono(channelPool.getChannelMono()));`
	`73`	`+ .resourceManagementChannelMono(channelPool.getChannelMono()`
	`74`	`+ .transform(Utils::cache)));`
`74`	`75`
`75`	`76`	`return new ReactiveMessageSender(sender, brokerConfigProps.getAppName(), converter, new TopologyCreator(sender));`
`76`	`77`	`}`