You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2014/08/26 17:18:40 UTC
svn commit: r1620629 -
/qpid/trunk/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java
Author: rgodfrey
Date: Tue Aug 26 15:18:40 2014
New Revision: 1620629
URL: http://svn.apache.org/r1620629
Log:
QPID-6046 : [Java Broker] [AMQP 1.0] when creating an outgoing link from the address amq.fanout (or any fanout exchange) bind the temporary queue to the exchange witht the queue name
Modified:
qpid/trunk/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java
Modified: qpid/trunk/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java?rev=1620629&r1=1620628&r2=1620629&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java (original)
+++ qpid/trunk/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java Tue Aug 26 15:18:40 2014
@@ -323,6 +323,19 @@ public class SendingLink_1_0 implements
{
exchange.addBinding(exchangeDestination.getInitialRoutingAddress(),queue,null);
}
+ if(binding == null
+ && exchangeDestination.getInitialRoutingAddress() != null
+ && exchange.getType().equals(ExchangeDefaults.FANOUT_EXCHANGE_CLASS))
+ {
+ exchange.addBinding(queue.getName(), queue, null);
+ }
+ else if(binding == null
+ && exchangeDestination.getInitialRoutingAddress() != null
+ && exchange.getType().equals(ExchangeDefaults.TOPIC_EXCHANGE_CLASS))
+ {
+ exchange.addBinding("#", queue, null);
+ }
+
source.setDistributionMode(StdDistMode.COPY);
qd = new QueueDestination(queue);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org