diff options
Diffstat (limited to 'cpp/src/qpid/ha/QueueReplicator.h')
| -rw-r--r-- | cpp/src/qpid/ha/QueueReplicator.h | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/cpp/src/qpid/ha/QueueReplicator.h b/cpp/src/qpid/ha/QueueReplicator.h index f8a68ea38f..a2a158539e 100644 --- a/cpp/src/qpid/ha/QueueReplicator.h +++ b/cpp/src/qpid/ha/QueueReplicator.h @@ -77,6 +77,10 @@ class QueueReplicator : public broker::Exchange, void route(broker::Deliverable&); bool isBound(boost::shared_ptr<broker::Queue>, const std::string* const, const framing::FieldTable* const); + // DataSource interface - used to write persistence data to async store + uint64_t getSize(); + void write(char* target); + private: void initializeBridge(broker::Bridge& bridge, broker::SessionHandler& sessionHandler); void dequeue(framing::SequenceNumber, sys::Mutex::ScopedLock&); |