From efc6473096622a01b2a3907093431b49d8ebfb1e Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 16 Nov 2009 11:58:45 +0000 Subject: Merge branch 'next_receiver_changes' into trunk git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@880718 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/messaging/Receiver.cpp | 1 - cpp/src/qpid/messaging/ReceiverImpl.h | 1 - cpp/src/qpid/messaging/Session.cpp | 15 --------------- cpp/src/qpid/messaging/SessionImpl.h | 3 --- 4 files changed, 20 deletions(-) (limited to 'cpp/src/qpid/messaging') diff --git a/cpp/src/qpid/messaging/Receiver.cpp b/cpp/src/qpid/messaging/Receiver.cpp index 3290ea98ac..76750cfc59 100644 --- a/cpp/src/qpid/messaging/Receiver.cpp +++ b/cpp/src/qpid/messaging/Receiver.cpp @@ -49,6 +49,5 @@ uint32_t Receiver::getCapacity() { return impl->getCapacity(); } uint32_t Receiver::available() { return impl->available(); } uint32_t Receiver::pendingAck() { return impl->pendingAck(); } void Receiver::cancel() { impl->cancel(); } -void Receiver::setListener(MessageListener* listener) { impl->setListener(listener); } }} // namespace qpid::messaging diff --git a/cpp/src/qpid/messaging/ReceiverImpl.h b/cpp/src/qpid/messaging/ReceiverImpl.h index 7db20acc29..e463559d99 100644 --- a/cpp/src/qpid/messaging/ReceiverImpl.h +++ b/cpp/src/qpid/messaging/ReceiverImpl.h @@ -48,7 +48,6 @@ class ReceiverImpl : public virtual qpid::RefCounted virtual uint32_t available() = 0; virtual uint32_t pendingAck() = 0; virtual void cancel() = 0; - virtual void setListener(MessageListener*) = 0; }; }} // namespace qpid::messaging diff --git a/cpp/src/qpid/messaging/Session.cpp b/cpp/src/qpid/messaging/Session.cpp index aa8e067168..53e85d53b1 100644 --- a/cpp/src/qpid/messaging/Session.cpp +++ b/cpp/src/qpid/messaging/Session.cpp @@ -75,21 +75,6 @@ void Session::flush() impl->flush(); } -bool Session::fetch(Message& message, qpid::sys::Duration timeout) -{ - return impl->fetch(message, timeout); -} - -Message Session::fetch(qpid::sys::Duration timeout) -{ - return impl->fetch(timeout); -} - -bool Session::dispatch(qpid::sys::Duration timeout) -{ - return impl->dispatch(timeout); -} - bool Session::nextReceiver(Receiver& receiver, qpid::sys::Duration timeout) { return impl->nextReceiver(receiver, timeout); diff --git a/cpp/src/qpid/messaging/SessionImpl.h b/cpp/src/qpid/messaging/SessionImpl.h index cf95e22ae8..b68baf821c 100644 --- a/cpp/src/qpid/messaging/SessionImpl.h +++ b/cpp/src/qpid/messaging/SessionImpl.h @@ -48,9 +48,6 @@ class SessionImpl : public virtual qpid::RefCounted virtual void close() = 0; virtual void sync() = 0; virtual void flush() = 0; - virtual bool fetch(Message& message, qpid::sys::Duration timeout) = 0; - virtual Message fetch(qpid::sys::Duration timeout) = 0; - virtual bool dispatch(qpid::sys::Duration timeout) = 0; virtual Sender createSender(const Address& address) = 0; virtual Receiver createReceiver(const Address& address) = 0; virtual bool nextReceiver(Receiver& receiver, qpid::sys::Duration timeout) = 0; -- cgit v1.2.1