diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-02-24 11:02:51 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-02-24 11:02:51 +0000 |
| commit | af2ea966a5c3ae635fe4cef016f2765e0b39a9ab (patch) | |
| tree | e389abd15de7fd4f5eca53df0dbf530cc263df85 /qpid/java | |
| parent | 49e140580a92b115e83b6aa41642d353b507f0e7 (diff) | |
| download | qpid-python-af2ea966a5c3ae635fe4cef016f2765e0b39a9ab.tar.gz | |
QPID-5577 : fix creation of exchanges so that setting alt exchange increases the referal count on the alt exchange
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1571232 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java index 9ffc305300..303818d7cb 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java @@ -119,21 +119,21 @@ public abstract class AbstractExchange<T extends Exchange> implements Exchange<T { if(alternateExchangeAttr instanceof Exchange) { - _alternateExchange = (Exchange) alternateExchangeAttr; + setAlternateExchange((Exchange) alternateExchangeAttr); } else if(alternateExchangeAttr instanceof UUID) { - _alternateExchange = vhost.getExchange((UUID)alternateExchangeAttr); + setAlternateExchange(vhost.getExchange((UUID)alternateExchangeAttr)); } else if(alternateExchangeAttr instanceof String) { - _alternateExchange = vhost.getExchange((String)alternateExchangeAttr); + setAlternateExchange(vhost.getExchange((String)alternateExchangeAttr)); if(_alternateExchange == null) { try { UUID altExcAsUUID = UUID.fromString((String)alternateExchangeAttr); - _alternateExchange = vhost.getExchange(altExcAsUUID); + setAlternateExchange(vhost.getExchange(altExcAsUUID)); } catch (IllegalArgumentException e) { |