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/02/24 12:02:51 UTC
svn commit: r1571232 -
/qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
Author: rgodfrey
Date: Mon Feb 24 11:02:51 2014
New Revision: 1571232
URL: http://svn.apache.org/r1571232
Log:
QPID-5577 : fix creation of exchanges so that setting alt exchange increases the referal count on the alt exchange
Modified:
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
Modified: qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java?rev=1571232&r1=1571231&r2=1571232&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java (original)
+++ qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java Mon Feb 24 11:02:51 2014
@@ -119,21 +119,21 @@ public abstract class AbstractExchange<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)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org