qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject svn commit: r1509420 - in /qpid/trunk/qpid/cpp/src/qpid: broker/ ha/
Date Thu, 01 Aug 2013 20:26:46 GMT
Author: aconway
Date: Thu Aug  1 20:26:45 2013
New Revision: 1509420

URL: http://svn.apache.org/r1509420
Log:
QPID-4327: Renamed ConfigurationObserver as BrokerObserver.

This class really was intended as a observer for broker-level events which
includes configuration but may in future include other non-configuration events
such as transactions.

Added:
    qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObserver.h   (contents, props changed)
      - copied, changed from r1509419, qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObserver.h
    qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObservers.h   (contents, props changed)
      - copied, changed from r1509419, qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObservers.h
Removed:
    qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObserver.h
    qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObservers.h
Modified:
    qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp
    qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h
    qpid/trunk/qpid/cpp/src/qpid/broker/ExchangeRegistry.cpp
    qpid/trunk/qpid/cpp/src/qpid/broker/QueueRegistry.cpp
    qpid/trunk/qpid/cpp/src/qpid/ha/HaBroker.cpp
    qpid/trunk/qpid/cpp/src/qpid/ha/Primary.cpp
    qpid/trunk/qpid/cpp/src/qpid/ha/Primary.h
    qpid/trunk/qpid/cpp/src/qpid/ha/QueueSnapshots.h
    qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.cpp
    qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.h

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp Thu Aug  1 20:26:45 2013
@@ -1446,7 +1446,7 @@ void Broker::bind(const std::string& que
         throw framing::NotFoundException(QPID_MSG("Bind failed. No such exchange: " <<
exchangeName));
     } else {
         if (queue->bind(exchange, key, arguments)) {
-            getConfigurationObservers().bind(exchange, queue, key, arguments);
+            getBrokerObservers().bind(exchange, queue, key, arguments);
             if (managementAgent.get()) {
                 managementAgent->raiseEvent(_qmf::EventBind(connectionId, userId, exchangeName,
                                                   queueName, key, ManagementAgent::toMap(arguments)));
@@ -1488,7 +1488,7 @@ void Broker::unbind(const std::string& q
             if (exchange->isDurable() && queue->isDurable()) {
                 store->unbind(*exchange, *queue, key, qpid::framing::FieldTable());
             }
-            getConfigurationObservers().unbind(
+            getBrokerObservers().unbind(
                 exchange, queue, key, framing::FieldTable());
             if (managementAgent.get()) {
                 managementAgent->raiseEvent(_qmf::EventUnbind(connectionId, userId, exchangeName,
queueName, key));

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h Thu Aug  1 20:26:45 2013
@@ -38,7 +38,7 @@
 #include "qpid/broker/System.h"
 #include "qpid/broker/ConsumerFactory.h"
 #include "qpid/broker/ConnectionObservers.h"
-#include "qpid/broker/ConfigurationObservers.h"
+#include "qpid/broker/BrokerObservers.h"
 #include "qpid/management/Manageable.h"
 #include "qpid/sys/ConnectionCodec.h"
 #include "qpid/sys/Mutex.h"
@@ -175,7 +175,7 @@ class Broker : public sys::Runnable, pub
     AclModule* acl;
     DataDir dataDir;
     ConnectionObservers connectionObservers;
-    ConfigurationObservers configurationObservers;
+    BrokerObservers brokerObservers;
 
     QueueRegistry queues;
     ExchangeRegistry exchanges;
@@ -352,7 +352,7 @@ class Broker : public sys::Runnable, pub
 
     ConsumerFactories&  getConsumerFactories() { return consumerFactories; }
     ConnectionObservers& getConnectionObservers() { return connectionObservers; }
-    ConfigurationObservers& getConfigurationObservers() { return configurationObservers;
}
+    BrokerObservers& getBrokerObservers() { return brokerObservers; }
 
     /** Properties to be set on outgoing link connections */
     QPID_BROKER_EXTERN framing::FieldTable getLinkClientProperties() const;

Copied: qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObserver.h (from r1509419, qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObserver.h)
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObserver.h?p2=qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObserver.h&p1=qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObserver.h&r1=1509419&r2=1509420&rev=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObserver.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObserver.h Thu Aug  1 20:26:45 2013
@@ -1,5 +1,5 @@
-#ifndef QPID_BROKER_CONFIGURATIONOBSERVER_H
-#define QPID_BROKER_CONFIGURATIONOBSERVER_H
+#ifndef QPID_BROKER_BROKEROBSERVER_H
+#define QPID_BROKER_BROKEROBSERVER_H
 
 /*
  *
@@ -43,10 +43,10 @@ class Exchange;
  * the registry lock held. This is necessary to ensure
  * they are called in the correct sequence.
  */
-class ConfigurationObserver
+class BrokerObserver
 {
   public:
-    virtual ~ConfigurationObserver() {}
+    virtual ~BrokerObserver() {}
     virtual void queueCreate(const boost::shared_ptr<Queue>&) {}
     virtual void queueDestroy(const boost::shared_ptr<Queue>&) {}
     virtual void exchangeCreate(const boost::shared_ptr<Exchange>&) {}
@@ -62,4 +62,4 @@ class ConfigurationObserver
 };
 }} // namespace qpid::broker
 
-#endif  /*!QPID_BROKER_CONFIGURATIONOBSERVER_H*/
+#endif  /*!QPID_BROKER_BROKEROBSERVER_H*/

Propchange: qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObserver.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObserver.h
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Copied: qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObservers.h (from r1509419, qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObservers.h)
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObservers.h?p2=qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObservers.h&p1=qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObservers.h&r1=1509419&r2=1509420&rev=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/ConfigurationObservers.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObservers.h Thu Aug  1 20:26:45 2013
@@ -1,5 +1,5 @@
-#ifndef QPID_BROKER_CONFIGURATIONOBSERVERS_H
-#define QPID_BROKER_CONFIGURATIONOBSERVERS_H
+#ifndef QPID_BROKER_BROKEROBSERVERS_H
+#define QPID_BROKER_BROKEROBSERVERS_H
 
 /*
  *
@@ -22,7 +22,7 @@
  *
  */
 
-#include "ConfigurationObserver.h"
+#include "BrokerObserver.h"
 #include "Observers.h"
 #include "qpid/sys/Mutex.h"
 
@@ -30,43 +30,42 @@ namespace qpid {
 namespace broker {
 
 /**
- * A configuration observer that delegates to a collection of
- * configuration observers.
+ * A broker observer that delegates to a collection of broker observers.
  *
  * THREAD SAFE
  */
-class ConfigurationObservers : public ConfigurationObserver,
-                               public Observers<ConfigurationObserver>
+class BrokerObservers : public BrokerObserver,
+                               public Observers<BrokerObserver>
 {
   public:
     void queueCreate(const boost::shared_ptr<Queue>& q) {
-        each(boost::bind(&ConfigurationObserver::queueCreate, _1, q));
+        each(boost::bind(&BrokerObserver::queueCreate, _1, q));
     }
     void queueDestroy(const boost::shared_ptr<Queue>& q) {
-        each(boost::bind(&ConfigurationObserver::queueDestroy, _1, q));
+        each(boost::bind(&BrokerObserver::queueDestroy, _1, q));
     }
     void exchangeCreate(const boost::shared_ptr<Exchange>& e) {
-        each(boost::bind(&ConfigurationObserver::exchangeCreate, _1, e));
+        each(boost::bind(&BrokerObserver::exchangeCreate, _1, e));
     }
     void exchangeDestroy(const boost::shared_ptr<Exchange>& e) {
-        each(boost::bind(&ConfigurationObserver::exchangeDestroy, _1, e));
+        each(boost::bind(&BrokerObserver::exchangeDestroy, _1, e));
     }
     void bind(const boost::shared_ptr<Exchange>& exchange,
               const boost::shared_ptr<Queue>& queue,
               const std::string& key,
               const framing::FieldTable& args) {
         each(boost::bind(
-                 &ConfigurationObserver::bind, _1, exchange, queue, key, args));
+                 &BrokerObserver::bind, _1, exchange, queue, key, args));
     }
     void unbind(const boost::shared_ptr<Exchange>& exchange,
                 const boost::shared_ptr<Queue>& queue,
                 const std::string& key,
                 const framing::FieldTable& args) {
         each(boost::bind(
-                 &ConfigurationObserver::unbind, _1, exchange, queue, key, args));
+                 &BrokerObserver::unbind, _1, exchange, queue, key, args));
     }
 };
 
 }} // namespace qpid::broker
 
-#endif  /*!QPID_BROKER_CONFIGURATIONOBSERVERS_H*/
+#endif  /*!QPID_BROKER_BROKEROBSERVERS_H*/

Propchange: qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObservers.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: qpid/trunk/qpid/cpp/src/qpid/broker/BrokerObservers.h
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/ExchangeRegistry.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/ExchangeRegistry.cpp?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/ExchangeRegistry.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/ExchangeRegistry.cpp Thu Aug  1 20:26:45 2013
@@ -81,7 +81,7 @@ pair<Exchange::shared_ptr, bool> Exchang
             result = std::pair<Exchange::shared_ptr, bool>(exchange, true);
             if (alternate) exchange->setAlternate(alternate);
             // Call exchangeCreate inside the lock to ensure correct ordering.
-            if (broker) broker->getConfigurationObservers().exchangeCreate(exchange);
+            if (broker) broker->getBrokerObservers().exchangeCreate(exchange);
         } else {
             result = std::pair<Exchange::shared_ptr, bool>(i->second, false);
         }
@@ -118,7 +118,7 @@ void ExchangeRegistry::destroy(
             if (broker) {
                 // Call exchangeDestroy and raiseEvent inside the lock to ensure
                 // correct ordering.
-                broker->getConfigurationObservers().exchangeDestroy(i->second);
+                broker->getBrokerObservers().exchangeDestroy(i->second);
                 if (broker->getManagementAgent())
                     broker->getManagementAgent()->raiseEvent(
                         _qmf::EventExchangeDelete(connectionId, userId, name));

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/QueueRegistry.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/QueueRegistry.cpp?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/QueueRegistry.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/QueueRegistry.cpp Thu Aug  1 20:26:45 2013
@@ -59,8 +59,8 @@ QueueRegistry::declare(const string& nam
         QueueMap::iterator i =  queues.find(name);
         if (i == queues.end()) {
             Queue::shared_ptr queue = create(name, settings);
-            // Allow ConfigurationObserver to modify settings before storing the message.
-            if (getBroker()) getBroker()->getConfigurationObservers().queueCreate(queue);
+            // Allow BrokerObserver to modify settings before storing the message.
+            if (getBroker()) getBroker()->getBrokerObservers().queueCreate(queue);
             //Move this to factory also?
             if (alternate)
                 queue->setAlternateExchange(alternate);//need to do this *before* create
@@ -100,7 +100,7 @@ void QueueRegistry::destroy(
                 // NOTE: queueDestroy and raiseEvent must be called with the
                 // lock held in order to ensure events are generated
                 // in the correct order.
-                getBroker()->getConfigurationObservers().queueDestroy(q);
+                getBroker()->getBrokerObservers().queueDestroy(q);
                 if (getBroker()->getManagementAgent())
                     getBroker()->getManagementAgent()->raiseEvent(
                         _qmf::EventQueueDelete(connectionId, userId, name));

Modified: qpid/trunk/qpid/cpp/src/qpid/ha/HaBroker.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/HaBroker.cpp?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/HaBroker.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/HaBroker.cpp Thu Aug  1 20:26:45 2013
@@ -82,7 +82,7 @@ HaBroker::HaBroker(broker::Broker& b, co
         broker.getExchanges().registerExchange(failoverExchange);
     }
     // QueueSnapshots are needed for standalone replication as well as cluster.
-    broker.getConfigurationObservers().add(queueSnapshots);
+    broker.getBrokerObservers().add(queueSnapshots);
 }
 
 namespace {

Modified: qpid/trunk/qpid/cpp/src/qpid/ha/Primary.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/Primary.cpp?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/Primary.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/Primary.cpp Thu Aug  1 20:26:45 2013
@@ -29,7 +29,7 @@
 #include "QueueReplicator.h"
 #include "qpid/assert.h"
 #include "qpid/broker/Broker.h"
-#include "qpid/broker/ConfigurationObserver.h"
+#include "qpid/broker/BrokerObserver.h"
 #include "qpid/broker/Connection.h"
 #include "qpid/broker/Queue.h"
 #include "qpid/framing/FieldTable.h"
@@ -59,10 +59,10 @@ class PrimaryConnectionObserver : public
     Primary& primary;
 };
 
-class PrimaryConfigurationObserver : public broker::ConfigurationObserver
+class PrimaryBrokerObserver : public broker::BrokerObserver
 {
   public:
-    PrimaryConfigurationObserver(Primary& p) : primary(p) {}
+    PrimaryBrokerObserver(Primary& p) : primary(p) {}
     void queueCreate(const Primary::QueuePtr& q) { primary.queueCreate(q); }
     void queueDestroy(const Primary::QueuePtr& q) { primary.queueDestroy(q); }
     void exchangeCreate(const Primary::ExchangePtr& q) { primary.exchangeCreate(q); }
@@ -98,7 +98,7 @@ Primary::Primary(HaBroker& hb, const Bro
         QPID_LOG(notice, logPrefix << "Promoted to primary. No expected backups.");
     }
     else {
-        // NOTE: RemoteBackups must be created before we set the ConfigurationObserver
+        // NOTE: RemoteBackups must be created before we set the BrokerObserver
         // or ConnectionObserver so that there is no client activity while
         // the QueueGuards are created.
         QPID_LOG(notice, logPrefix << "Promoted to primary. Expected backups: " <<
expect);
@@ -113,8 +113,8 @@ Primary::Primary(HaBroker& hb, const Bro
         timerTask = new ExpectedBackupTimerTask(*this, deadline);
         hb.getBroker().getTimer().add(timerTask);
     }
-    configurationObserver.reset(new PrimaryConfigurationObserver(*this));
-    haBroker.getBroker().getConfigurationObservers().add(configurationObserver);
+    brokerObserver.reset(new PrimaryBrokerObserver(*this));
+    haBroker.getBroker().getBrokerObservers().add(brokerObserver);
     checkReady();               // Outside lock
 
     // Allow client connections
@@ -124,7 +124,7 @@ Primary::Primary(HaBroker& hb, const Bro
 
 Primary::~Primary() {
     if (timerTask) timerTask->cancel();
-    haBroker.getBroker().getConfigurationObservers().remove(configurationObserver);
+    haBroker.getBroker().getBrokerObservers().remove(brokerObserver);
     haBroker.getObserver()->reset();
 }
 

Modified: qpid/trunk/qpid/cpp/src/qpid/ha/Primary.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/Primary.h?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/Primary.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/Primary.h Thu Aug  1 20:26:45 2013
@@ -38,7 +38,7 @@ namespace broker {
 class Queue;
 class Connection;
 class ConnectionObserver;
-class ConfigurationObserver;
+class BrokerObserver;
 }
 
 namespace sys {
@@ -79,7 +79,7 @@ class Primary : public Role
     void readyReplica(const ReplicatingSubscription&);
     void removeReplica(const std::string& q);
 
-    // Called via ConfigurationObserver
+    // Called via BrokerObserver
     void queueCreate(const QueuePtr&);
     void queueDestroy(const QueuePtr&);
     void exchangeCreate(const ExchangePtr&);
@@ -126,7 +126,7 @@ class Primary : public Role
      */
     BackupMap backups;
     boost::shared_ptr<broker::ConnectionObserver> connectionObserver;
-    boost::shared_ptr<broker::ConfigurationObserver> configurationObserver;
+    boost::shared_ptr<broker::BrokerObserver> brokerObserver;
     boost::intrusive_ptr<sys::TimerTask> timerTask;
     static Primary* instance;
 };

Modified: qpid/trunk/qpid/cpp/src/qpid/ha/QueueSnapshots.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/QueueSnapshots.h?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/QueueSnapshots.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/QueueSnapshots.h Thu Aug  1 20:26:45 2013
@@ -27,7 +27,7 @@
 #include "hash.h"
 
 #include "qpid/assert.h"
-#include "qpid/broker/ConfigurationObserver.h"
+#include "qpid/broker/BrokerObserver.h"
 #include "qpid/broker/Queue.h"
 #include "qpid/sys/Mutex.h"
 
@@ -37,10 +37,10 @@ namespace qpid {
 namespace ha {
 
 /**
- * ConfigurationObserver that maintains a map of the QueueSnapshot for each queue.
+ * BrokerObserver that maintains a map of the QueueSnapshot for each queue.
  * THREAD SAFE.
  */
-class QueueSnapshots : public broker::ConfigurationObserver
+class QueueSnapshots : public broker::BrokerObserver
 {
   public:
     boost::shared_ptr<QueueSnapshot> get(const boost::shared_ptr<broker::Queue>&
q) const {
@@ -49,7 +49,7 @@ class QueueSnapshots : public broker::Co
         return i != snapshots.end() ? i->second : boost::shared_ptr<QueueSnapshot>();
     }
 
-    // ConfigurationObserver overrides.
+    // BrokerObserver overrides.
     void queueCreate(const boost::shared_ptr<broker::Queue>& q) {
         sys::Mutex::ScopedLock l(lock);
         boost::shared_ptr<QueueSnapshot> observer(new QueueSnapshot);

Modified: qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.cpp?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.cpp Thu Aug  1 20:26:45 2013
@@ -108,13 +108,13 @@ void RemoteBackup::ready(const QueuePtr&
         QPID_LOG(debug, logPrefix << "Caught up on queue: " << q->getName()
);
 }
 
-// Called via ConfigurationObserver::queueCreate and from catchupQueue
+// Called via BrokerObserver::queueCreate and from catchupQueue
 void RemoteBackup::queueCreate(const QueuePtr& q) {
     if (replicationTest.getLevel(*q) == ALL)
         guards[q].reset(new QueueGuard(*q, brokerInfo));
 }
 
-// Called via ConfigurationObserver
+// Called via BrokerObserver
 void RemoteBackup::queueDestroy(const QueuePtr& q) {
     catchupQueues.erase(q);
     GuardMap::iterator i = guards.find(q);

Modified: qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.h?rev=1509420&r1=1509419&r2=1509420&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/RemoteBackup.h Thu Aug  1 20:26:45 2013
@@ -71,10 +71,10 @@ class RemoteBackup
      */
     void ready(const QueuePtr& queue);
 
-    /** Called via ConfigurationObserver */
+    /** Called via BrokerObserver */
     void queueCreate(const QueuePtr&);
 
-    /** Called via ConfigurationObserver. Note: may set isReady() */
+    /** Called via BrokerObserver. Note: may set isReady() */
     void queueDestroy(const QueuePtr&);
 
     /**@return true when all catch-up queues for this backup are ready. */



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message