diff options
Diffstat (limited to 'cpp/src/qpid/broker/Queue.cpp')
-rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 10 |
1 files changed, 0 insertions, 10 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index b99b849bcc..dcc5116afa 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/cpp/src/qpid/broker/Queue.cpp @@ -124,16 +124,6 @@ Queue::~Queue() mgmtObject->resourceDestroy (); } -void Queue::notifyDurableIOComplete() -{ - QueueListeners::NotificationSet copy; - { - Mutex::ScopedLock locker(messageLock); - listeners.populate(copy); - } - copy.notify(); -} - bool isLocalTo(const OwnershipToken* token, boost::intrusive_ptr<Message>& msg) { return token && token->isLocal(msg->getPublisher()); |