diff options
| author | Alan Conway <aconway@apache.org> | 2012-06-12 21:19:48 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2012-06-12 21:19:48 +0000 |
| commit | bf69fd2f69325dd660454e6b6c8399c51cacea2c (patch) | |
| tree | cd17f5a4c546a4a26c8456a5a143fe7de776a7cd /qpid/cpp/src/CMakeLists.txt | |
| parent | 379b80858ea24a3909657aa2b35bf61ff1322fee (diff) | |
| download | qpid-python-bf69fd2f69325dd660454e6b6c8399c51cacea2c.tar.gz | |
QPID-3603: Separate QueueGuard from ReplicatingSubscription.
QueueGuard: implements QueueObserver to delay completion of new messages.
ReplicatingSubscription: Implements subscription, sends messages & events to backup.
These were previously combined as one. QueueGuard is now separated out
so that it can be created before the ReplicatingSubscription, in
anticipation of an expected backup connecting. This is needed for 2 reasons:
- new queues must be guarded until they are backuped up.
- after a failover, all queues must be guarded until backups are ready.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1349538 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/CMakeLists.txt')
| -rw-r--r-- | qpid/cpp/src/CMakeLists.txt | 23 |
1 files changed, 15 insertions, 8 deletions
diff --git a/qpid/cpp/src/CMakeLists.txt b/qpid/cpp/src/CMakeLists.txt index aee5fb6213..b83e8d9c6d 100644 --- a/qpid/cpp/src/CMakeLists.txt +++ b/qpid/cpp/src/CMakeLists.txt @@ -626,31 +626,38 @@ set (ha_default ON) option(BUILD_HA "Build Active-Passive HA plugin" ${ha_default}) if (BUILD_HA) set (ha_SOURCES + qpid/ha/BackupConnectionExcluder.h + qpid/ha/BrokerInfo.cpp + qpid/ha/BrokerInfo.h + qpid/ha/HeldQueue.h + qpid/ha/QueueGuard.cpp + qpid/ha/QueueGuard.h + qpid/ha/ReplicationTest.cpp + qpid/ha/ReplicationTest.h qpid/ha/Backup.cpp qpid/ha/Backup.h - qpid/ha/BrokerInfo.h - qpid/ha/BrokerInfo.cpp qpid/ha/BrokerReplicator.cpp qpid/ha/BrokerReplicator.h - qpid/ha/ConnectionExcluder.cpp - qpid/ha/ConnectionExcluder.h + qpid/ha/ConnectionObserver.cpp + qpid/ha/ConnectionObserver.h qpid/ha/Counter.h - qpid/ha/Enum.cpp - qpid/ha/Enum.h qpid/ha/HaBroker.cpp qpid/ha/HaBroker.h qpid/ha/HaPlugin.cpp - qpid/ha/LogPrefix.cpp - qpid/ha/LogPrefix.h qpid/ha/Membership.cpp qpid/ha/Membership.h qpid/ha/Primary.cpp qpid/ha/Primary.h + qpid/ha/PrimaryConnectionMonitor.h qpid/ha/QueueReplicator.cpp qpid/ha/QueueReplicator.h qpid/ha/ReplicatingSubscription.cpp qpid/ha/ReplicatingSubscription.h qpid/ha/Settings.h + qpid/ha/Types.cpp + qpid/ha/Types.h + qpid/ha/UnreadyQueueSet.cpp + qpid/ha/UnreadyQueueSet.h ) add_library (ha MODULE ${ha_SOURCES}) |