summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/ha/QueueReplicator.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2012-11-14 19:51:37 +0000
committerAlan Conway <aconway@apache.org>2012-11-14 19:51:37 +0000
commit2b975dc903f16e67ad25cb1360d76904417e0643 (patch)
treefd001bfd323b8118328fd25cee6640e0cefb6778 /cpp/src/qpid/ha/QueueReplicator.cpp
parentc3dbcaba9dadd21dd4c85bcefdeb4aff095258b2 (diff)
downloadqpid-python-2b975dc903f16e67ad25cb1360d76904417e0643.tar.gz
QPID-4436: HA fix qpidd crash when mgmt-enable=no
- Don't initialize HaBroker if management is disabled. - Fix use of constants from another compilation unit in QueueReplicator. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1409327 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/ha/QueueReplicator.cpp')
-rw-r--r--cpp/src/qpid/ha/QueueReplicator.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/cpp/src/qpid/ha/QueueReplicator.cpp b/cpp/src/qpid/ha/QueueReplicator.cpp
index 1f14ce4669..6b270b41d3 100644
--- a/cpp/src/qpid/ha/QueueReplicator.cpp
+++ b/cpp/src/qpid/ha/QueueReplicator.cpp
@@ -40,6 +40,7 @@
namespace {
const std::string QPID_REPLICATOR_("qpid.replicator-");
const std::string TYPE_NAME("qpid.queue-replicator");
+const std::string QPID_HA("qpid.ha-");
}
namespace qpid {
@@ -49,8 +50,8 @@ using namespace framing;
using namespace std;
using sys::Mutex;
-const std::string QueueReplicator::DEQUEUE_EVENT_KEY(QPID_HA_PREFIX+"dequeue");
-const std::string QueueReplicator::POSITION_EVENT_KEY(QPID_HA_PREFIX+"position");
+const std::string QueueReplicator::DEQUEUE_EVENT_KEY(QPID_HA+"dequeue");
+const std::string QueueReplicator::POSITION_EVENT_KEY(QPID_HA+"position");
const std::string QueueReplicator::QPID_SYNC_FREQUENCY("qpid.sync_frequency");
std::string QueueReplicator::replicatorName(const std::string& queueName) {
@@ -62,7 +63,7 @@ bool QueueReplicator::isReplicatorName(const std::string& name) {
}
bool QueueReplicator::isEventKey(const std::string key) {
- const std::string& prefix = QPID_HA_PREFIX;
+ const std::string& prefix = QPID_HA;
bool ret = key.size() > prefix.size() && key.compare(0, prefix.size(), prefix) == 0;
return ret;
}