diff options
Diffstat (limited to 'qpid/java')
| -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 | 4 |
1 files changed, 2 insertions, 2 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 660575e364..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 @@ -324,13 +324,13 @@ public class SendingLink_1_0 implements SendingLinkListener, Link_1_0, DeliveryS exchange.addBinding(exchangeDestination.getInitialRoutingAddress(),queue,null); } if(binding == null - && exchangeDestination.getInitialRoutingAddress() != null + && exchangeDestination.getInitialRoutingAddress() == null && exchange.getType().equals(ExchangeDefaults.FANOUT_EXCHANGE_CLASS)) { exchange.addBinding(queue.getName(), queue, null); } else if(binding == null - && exchangeDestination.getInitialRoutingAddress() != null + && exchangeDestination.getInitialRoutingAddress() == null && exchange.getType().equals(ExchangeDefaults.TOPIC_EXCHANGE_CLASS)) { exchange.addBinding("#", queue, null); |