diff options
Diffstat (limited to 'cpp/src/qpid/ha')
-rw-r--r-- | cpp/src/qpid/ha/BrokerReplicator.cpp | 10 | ||||
-rw-r--r-- | cpp/src/qpid/ha/BrokerReplicator.h | 5 | ||||
-rw-r--r-- | cpp/src/qpid/ha/QueueReplicator.cpp | 4 | ||||
-rw-r--r-- | cpp/src/qpid/ha/QueueReplicator.h | 5 |
4 files changed, 12 insertions, 12 deletions
diff --git a/cpp/src/qpid/ha/BrokerReplicator.cpp b/cpp/src/qpid/ha/BrokerReplicator.cpp index 0a66527e98..3a3c9c2954 100644 --- a/cpp/src/qpid/ha/BrokerReplicator.cpp +++ b/cpp/src/qpid/ha/BrokerReplicator.cpp @@ -398,7 +398,7 @@ void BrokerReplicator::doEventBind(Variant::Map& values) { QPID_LOG(debug, logPrefix << "Bind event: exchange=" << exchange->getName() << " queue=" << queue->getName() << " key=" << key); - exchange->bind(queue, key, &args); + exchange->bind(queue, key, &args, 0); } } @@ -418,7 +418,7 @@ void BrokerReplicator::doEventUnbind(Variant::Map& values) { QPID_LOG(debug, logPrefix << "Unbind event: exchange=" << exchange->getName() << " queue=" << queue->getName() << " key=" << key); - exchange->unbind(queue, key, &args); + exchange->unbind(queue, key, &args, 0); } } @@ -514,7 +514,7 @@ void BrokerReplicator::doResponseBind(Variant::Map& values) { << " key:" << key); framing::FieldTable args; qpid::amqp_0_10::translate(asMapVoid(values[ARGUMENTS]), args); - exchange->bind(queue, key, &args); + exchange->bind(queue, key, &args, 0); } } @@ -616,8 +616,8 @@ boost::shared_ptr<Exchange> BrokerReplicator::createExchange( else return boost::shared_ptr<Exchange>(); } -bool BrokerReplicator::bind(boost::shared_ptr<Queue>, const string&, const framing::FieldTable*) { return false; } -bool BrokerReplicator::unbind(boost::shared_ptr<Queue>, const string&, const framing::FieldTable*) { return false; } +bool BrokerReplicator::bind(boost::shared_ptr<Queue>, const string&, const framing::FieldTable*, qpid::broker::AsyncStore* const) { return false; } +bool BrokerReplicator::unbind(boost::shared_ptr<Queue>, const string&, const framing::FieldTable*, qpid::broker::AsyncStore* const) { return false; } bool BrokerReplicator::isBound(boost::shared_ptr<Queue>, const string* const, const framing::FieldTable* const) { return false; } // DataSource interface - used to write persistence data to async store diff --git a/cpp/src/qpid/ha/BrokerReplicator.h b/cpp/src/qpid/ha/BrokerReplicator.h index 109d8c638e..f6983e8719 100644 --- a/cpp/src/qpid/ha/BrokerReplicator.h +++ b/cpp/src/qpid/ha/BrokerReplicator.h @@ -35,6 +35,7 @@ namespace qpid { namespace broker { +class AsyncStore; class Broker; class Link; class Bridge; @@ -71,8 +72,8 @@ class BrokerReplicator : public broker::Exchange, // Exchange methods std::string getType() const; - bool bind(boost::shared_ptr<broker::Queue>, const std::string&, const framing::FieldTable*); - bool unbind(boost::shared_ptr<broker::Queue>, const std::string&, const framing::FieldTable*); + bool bind(boost::shared_ptr<broker::Queue>, const std::string&, const framing::FieldTable*, qpid::broker::AsyncStore* const store); + bool unbind(boost::shared_ptr<broker::Queue>, const std::string&, const framing::FieldTable*, qpid::broker::AsyncStore* const store); void route(broker::Deliverable&); bool isBound(boost::shared_ptr<broker::Queue>, const std::string* const, const framing::FieldTable* const); diff --git a/cpp/src/qpid/ha/QueueReplicator.cpp b/cpp/src/qpid/ha/QueueReplicator.cpp index 8aba7555d4..cac1fdac29 100644 --- a/cpp/src/qpid/ha/QueueReplicator.cpp +++ b/cpp/src/qpid/ha/QueueReplicator.cpp @@ -190,8 +190,8 @@ void QueueReplicator::route(Deliverable& msg) } // Unused Exchange methods. -bool QueueReplicator::bind(boost::shared_ptr<Queue>, const std::string&, const FieldTable*) { return false; } -bool QueueReplicator::unbind(boost::shared_ptr<Queue>, const std::string&, const FieldTable*) { return false; } +bool QueueReplicator::bind(boost::shared_ptr<Queue>, const std::string&, const FieldTable*, qpid::broker::AsyncStore* const) { return false; } +bool QueueReplicator::unbind(boost::shared_ptr<Queue>, const std::string&, const FieldTable*, qpid::broker::AsyncStore* const) { return false; } bool QueueReplicator::isBound(boost::shared_ptr<Queue>, const std::string* const, const FieldTable* const) { return false; } std::string QueueReplicator::getType() const { return TYPE_NAME; } diff --git a/cpp/src/qpid/ha/QueueReplicator.h b/cpp/src/qpid/ha/QueueReplicator.h index a2a158539e..8d8a41a5ba 100644 --- a/cpp/src/qpid/ha/QueueReplicator.h +++ b/cpp/src/qpid/ha/QueueReplicator.h @@ -71,9 +71,8 @@ class QueueReplicator : public broker::Exchange, void deactivate(); // Call before dtor std::string getType() const; - bool bind(boost::shared_ptr<broker::Queue - >, const std::string&, const framing::FieldTable*); - bool unbind(boost::shared_ptr<broker::Queue>, const std::string&, const framing::FieldTable*); + bool bind(boost::shared_ptr<broker::Queue>, const std::string&, const framing::FieldTable*, qpid::broker::AsyncStore* const); + bool unbind(boost::shared_ptr<broker::Queue>, const std::string&, const framing::FieldTable*, qpid::broker::AsyncStore* const); void route(broker::Deliverable&); bool isBound(boost::shared_ptr<broker::Queue>, const std::string* const, const framing::FieldTable* const); |