From e46c3c0a19af0fd659cfe018c34db1c0dfd498c5 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 15 Jan 2009 11:29:38 +0000 Subject: QPID-1567: Initial support for asynchronous queue state replication * Added QueueEvents class with per broker instance * Modified qpid::broker::Queue to notify QueueEvents of enqueues and dequeues (based on configuration) * Added replication subdir containing two plugins: - an event listener that registers with QueueEvents and creates messages representing received events on a replication queue - a custom exchange type for processing messages of the format created by the listener plugin * Added new option for controlling event generation to qpid::client::QueueOptions * Added new queue option to qpid-config script for the same git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734674 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/Makefile.am | 3 +++ 1 file changed, 3 insertions(+) (limited to 'cpp/src/Makefile.am') diff --git a/cpp/src/Makefile.am b/cpp/src/Makefile.am index 27592f09ed..e3331daa00 100644 --- a/cpp/src/Makefile.am +++ b/cpp/src/Makefile.am @@ -184,6 +184,7 @@ include qmfc.mk if HAVE_XML include xml.mk endif +include replication.mk if RDMA @@ -400,6 +401,7 @@ libqpidbroker_la_SOURCES = \ qpid/broker/NameGenerator.cpp \ qpid/broker/NullMessageStore.cpp \ qpid/broker/QueueBindings.cpp \ + qpid/broker/QueueEvents.cpp \ qpid/broker/QueuePolicy.cpp \ qpid/broker/QueueRegistry.cpp \ qpid/broker/RateTracker.cpp \ @@ -545,6 +547,7 @@ nobase_include_HEADERS = \ qpid/broker/PersistableMessage.h \ qpid/broker/PersistableQueue.h \ qpid/broker/QueueBindings.h \ + qpid/broker/QueueEvents.h \ qpid/broker/QueuedMessage.h \ qpid/broker/QueuePolicy.h \ qpid/broker/QueueRegistry.h \ -- cgit v1.2.1