diff options
author | Robert Godfrey <rgodfrey@apache.org> | 2014-08-26 19:50:26 +0000 |
---|---|---|
committer | Robert Godfrey <rgodfrey@apache.org> | 2014-08-26 19:50:26 +0000 |
commit | 06e710fb6ca4a6748e37747453f8635ddfc68493 (patch) | |
tree | 44ddfff6678d7716382267ce21bd8d95938a6ba1 | |
parent | e7da5d6cbbf402aafc6772043cb6b003958cd4b8 (diff) | |
download | qpid-python-06e710fb6ca4a6748e37747453f8635ddfc68493.tar.gz |
QPID-6066 : Merged from trunk onto the 0.30 branch
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.30@1620715 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java b/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java index def75527f3..2cfe431979 100644 --- a/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java +++ b/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java @@ -323,6 +323,19 @@ public class SendingLink_1_0 implements SendingLinkListener, Link_1_0, DeliveryS { 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); |