From 335bb609fc9b4eebbf69a5f0eb20990942e21d9e Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Tue, 21 May 2019 12:33:24 -0400 Subject: [PATCH] GH-245: Use AnonymouseQueue when provisioning Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/245 Use `AnonymousQueue` so that the master locator argument is set appropriately. **cherry-pick to 2.1.x**` Resolves #246 --- .../rabbit/provisioning/RabbitExchangeQueueProvisioner.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java b/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java index 7e066e232..193b461b9 100644 --- a/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java +++ b/spring-cloud-stream-binder-rabbit-core/src/main/java/org/springframework/cloud/stream/binder/rabbit/provisioning/RabbitExchangeQueueProvisioner.java @@ -24,6 +24,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.springframework.amqp.AmqpConnectException; +import org.springframework.amqp.core.AnonymousQueue; import org.springframework.amqp.core.Base64UrlNamingStrategy; import org.springframework.amqp.core.Binding; import org.springframework.amqp.core.Binding.DestinationType; @@ -194,7 +195,8 @@ public class RabbitExchangeQueueProvisioner boolean durable = !anonymous && properties.getExtension().isDurableSubscription(); Queue queue; if (anonymous) { - queue = new Queue(queueName, false, true, true, + String anonQueueName = queueName; + queue = new AnonymousQueue((org.springframework.amqp.core.NamingStrategy) () -> anonQueueName, queueArgs(queueName, properties.getExtension(), false)); } else {