diff options
Diffstat (limited to 'cpp/src/qpid/broker/Consumer.h')
| -rw-r--r-- | cpp/src/qpid/broker/Consumer.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Consumer.h b/cpp/src/qpid/broker/Consumer.h index 5e09a00113..ed4bb176f6 100644 --- a/cpp/src/qpid/broker/Consumer.h +++ b/cpp/src/qpid/broker/Consumer.h @@ -53,7 +53,9 @@ namespace qpid { Consumer(bool preAcquires = true) : acquires(preAcquires) {} bool preAcquires() const { return acquires; } virtual bool deliver(QueuedMessage& msg) = 0; + virtual void notify() = 0; virtual bool filter(intrusive_ptr<Message>) { return true; } + virtual bool accept(intrusive_ptr<Message>) { return true; } virtual ~Consumer(){} }; } |