diff options
Diffstat (limited to 'qpid/cpp/src/qpid/ha/ReplicatingSubscription.h')
-rw-r--r-- | qpid/cpp/src/qpid/ha/ReplicatingSubscription.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h b/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h index 31246507c9..688d2b7726 100644 --- a/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h +++ b/qpid/cpp/src/qpid/ha/ReplicatingSubscription.h @@ -104,10 +104,11 @@ class ReplicatingSubscription : public broker::SemanticState::ConsumerImpl, ~DelegatingConsumer(); bool deliver(broker::QueuedMessage& msg); void notify(); - bool filter(boost::intrusive_ptr<Message>); - bool accept(boost::intrusive_ptr<Message>); + bool filter(boost::intrusive_ptr<broker::Message>); + bool accept(boost::intrusive_ptr<broker::Message>); void cancel(); - OwnershipToken* getSession(); + bool isDelayedCompletion() const { return false; } + broker::OwnershipToken* getSession(); private: ReplicatingSubscription& delegate; }; |