diff options
Diffstat (limited to 'cpp/src/qpid/ha/ReplicationTest.cpp')
| -rw-r--r-- | cpp/src/qpid/ha/ReplicationTest.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/cpp/src/qpid/ha/ReplicationTest.cpp b/cpp/src/qpid/ha/ReplicationTest.cpp index 88a969dbfd..1dd32262a0 100644 --- a/cpp/src/qpid/ha/ReplicationTest.cpp +++ b/cpp/src/qpid/ha/ReplicationTest.cpp @@ -20,6 +20,7 @@ */ #include "ReplicationTest.h" #include "qpid/broker/Queue.h" +#include "qpid/broker/Exchange.h" #include "qpid/framing/FieldTable.h" namespace qpid { @@ -71,5 +72,10 @@ bool ReplicationTest::isReplicated(ReplicateLevel level, const broker::Queue& q) return isReplicated(level, q.getSettings().storeSettings, q.isAutoDelete(), q.hasExclusiveOwner()); } +bool ReplicationTest::isReplicated(ReplicateLevel level, const broker::Exchange& ex) +{ + return replicateLevel(ex.getArgs()) >= level; +} + }} // namespace qpid::ha |