Skip to content

Commit 8352b44

Browse files
author
Daniel Bustamante Ospina
committed
Fix compilation (merge) RabbitMqConfig
1 parent f906fed commit 8352b44

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

async/async-commons-standalone/src/main/java/org/reactivecommons/async/impl/config/RabbitMqConfig.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,14 +37,14 @@ public ReactiveMessageSender messageSender(ConnectionFactoryProvider provider, M
3737

3838
final Sender sender = RabbitFlux.createSender(new SenderOptions().channelPool(channelPool));
3939

40-
return new ReactiveMessageSender(sender, appName, converter, new TopologyCreator(senderConnection));
40+
return new ReactiveMessageSender(sender, appName, converter, new TopologyCreator(sender));
4141
}
4242

43-
public ReactiveMessageListener messageListener(ConnectionFactoryProvider provider) {
43+
/*public ReactiveMessageListener messageListener(ConnectionFactoryProvider provider) {
4444
final Mono<Connection> connection = createSenderConnectionMono(provider.getConnectionFactory(), "listener");
4545
Receiver receiver = RabbitFlux.createReceiver(new ReceiverOptions().connectionMono(connection));
4646
return new ReactiveMessageListener(receiver, new TopologyCreator(connection));
47-
}
47+
}*/
4848

4949
public ConnectionFactoryProvider connectionFactory(RabbitProperties properties) {
5050
final ConnectionFactory factory = new ConnectionFactory();

gradle.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
version=0.2.1-beta1
1+
version=0.3.0-beta1
22
springBootVersion=2.2.1.RELEASE
33
gradleVersionsVersion=0.27.0
44

0 commit comments

Comments
 (0)