diff options
Diffstat (limited to 'qpid/cpp/src/qpid/ha/ReplicatingSubscription.h')
-rw-r--r-- | qpid/cpp/src/qpid/ha/ReplicatingSubscription.h | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h b/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h index 688d2b7726..ddee9c8658 100644 --- a/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h +++ b/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h @@ -88,6 +88,7 @@ class ReplicatingSubscription : public broker::SemanticState::ConsumerImpl, protected: bool doDispatch(); private: + std::string logPrefix; boost::shared_ptr<broker::Queue> events; boost::shared_ptr<broker::Consumer> consumer; qpid::framing::SequenceSet dequeues; @@ -97,6 +98,7 @@ class ReplicatingSubscription : public broker::SemanticState::ConsumerImpl, void sendPositionEvent(framing::SequenceNumber, const sys::Mutex::ScopedLock&); void sendEvent(const std::string& key, framing::Buffer&, const sys::Mutex::ScopedLock&); + class DelegatingConsumer : public Consumer { public: @@ -112,9 +114,6 @@ class ReplicatingSubscription : public broker::SemanticState::ConsumerImpl, private: ReplicatingSubscription& delegate; }; - - /** Print a identifier for a ReplicatingSubscription */ - friend std::ostream& operator<<(std::ostream&, const ReplicatingSubscription&); }; |