summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/ha/ReplicatingSubscription.h')
-rw-r--r--qpid/cpp/src/qpid/ha/ReplicatingSubscription.h5
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&);
};