summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/cluster/exp/QueueReplica.h')
-rw-r--r--qpid/cpp/src/qpid/cluster/exp/QueueReplica.h13
1 files changed, 3 insertions, 10 deletions
diff --git a/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h b/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h
index a322a8b9c0..4ebbc84ef0 100644
--- a/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h
+++ b/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h
@@ -35,7 +35,6 @@ class Queue;
}
namespace cluster {
-class QueueHandler;
class QueueContext;
/**
@@ -56,15 +55,9 @@ class QueueReplica : public RefCounted
void resubscribe(const MemberId&);
private:
- enum State {
- UNSUBSCRIBED,
- SUBSCRIBED,
- SOLE_OWNER,
- SHARED_OWNER
- };
friend class PrintSubscribers;
- friend std::ostream& operator<<(std::ostream&, State);
+ friend std::ostream& operator<<(std::ostream&, QueueOwnership);
friend std::ostream& operator<<(std::ostream&, const QueueReplica&);
typedef std::deque<MemberId> MemberQueue;
@@ -74,10 +67,10 @@ class QueueReplica : public RefCounted
MemberId self;
boost::intrusive_ptr<QueueContext> context;
- State getState() const;
+ QueueOwnership getState() const;
bool isOwner() const;
bool isSubscriber(const MemberId&) const;
- void update(State before);
+ void update(QueueOwnership before);
};
}} // namespace qpid::cluster