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/ha.mk | |
| 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/ha.mk')
| -rw-r--r-- | qpid/cpp/src/ha.mk | 23 |
1 files changed, 15 insertions, 8 deletions
diff --git a/qpid/cpp/src/ha.mk b/qpid/cpp/src/ha.mk index cab7d8c42b..dae924b6ea 100644 --- a/qpid/cpp/src/ha.mk +++ b/qpid/cpp/src/ha.mk @@ -25,29 +25,36 @@ dmoduleexec_LTLIBRARIES += ha.la ha_la_SOURCES = \ qpid/ha/Backup.cpp \ qpid/ha/Backup.h \ - qpid/ha/BrokerInfo.h \ + qpid/ha/BackupConnectionExcluder.h \ qpid/ha/BrokerInfo.cpp \ + qpid/ha/BrokerInfo.h \ 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/HeldQueue.h \ qpid/ha/Membership.cpp \ qpid/ha/Membership.h \ qpid/ha/Primary.cpp \ qpid/ha/Primary.h \ + qpid/ha/PrimaryConnectionMonitor. \ + qpid/ha/QueueGuard.cpp \ + qpid/ha/QueueGuard.h \ qpid/ha/QueueReplicator.cpp \ qpid/ha/QueueReplicator.h \ qpid/ha/ReplicatingSubscription.cpp \ qpid/ha/ReplicatingSubscription.h \ - qpid/ha/Settings.h + qpid/ha/ReplicationTest.cpp \ + qpid/ha/ReplicationTest.h \ + qpid/ha/Settings.h \ + qpid/ha/UnreadyQueueSet.cpp \ + qpid/ha/UnreadyQueueSet.h \ + qpid/ha/types.cpp \ + qpid/ha/types.h ha_la_LIBADD = libqpidbroker.la ha_la_LDFLAGS = $(PLUGINLDFLAGS) |