You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2011/04/19 22:55:50 UTC
svn commit: r1095209 - /qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp
Author: aconway
Date: Tue Apr 19 20:55:50 2011
New Revision: 1095209
URL: http://svn.apache.org/viewvc?rev=1095209&view=rev
Log:
QPID-3217: Exchanges with IVE option cause cluster inconsistencies in updatees
Since this option is rarely used, the short term fix is to disallow IVE in a cluster.
This is not a regression since it didn't work anyway.
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp?rev=1095209&r1=1095208&r2=1095209&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp Tue Apr 19 20:55:50 2011
@@ -201,7 +201,11 @@ Exchange::Exchange(const string& _name,
}
ive = _args.get(qpidIVE);
- if (ive) QPID_LOG(debug, "Configured exchange " << _name << " with Initial Value");
+ if (ive) {
+ if (broker && broker->isInCluster())
+ throw framing::NotImplementedException("Cannot use Initial Value Exchanges in a cluster");
+ QPID_LOG(debug, "Configured exchange " << _name << " with Initial Value");
+ }
}
Exchange::~Exchange ()
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org