diff options
Diffstat (limited to 'cpp/src/qpid/client/Dispatcher.h')
| -rw-r--r-- | cpp/src/qpid/client/Dispatcher.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/client/Dispatcher.h b/cpp/src/qpid/client/Dispatcher.h index e23d0c198c..1b31ddf4cf 100644 --- a/cpp/src/qpid/client/Dispatcher.h +++ b/cpp/src/qpid/client/Dispatcher.h @@ -37,13 +37,13 @@ namespace client { class Subscriber : public MessageListener { - Session& session; + AsyncSession session; MessageListener* const listener; AckPolicy autoAck; public: typedef boost::shared_ptr<Subscriber> shared_ptr; - Subscriber(Session& session, MessageListener* listener, AckPolicy); + Subscriber(const Session& session, MessageListener* listener, AckPolicy); void received(Message& msg); }; @@ -55,7 +55,7 @@ class Dispatcher : public sys::Runnable typedef std::map<std::string, Subscriber::shared_ptr> Listeners; sys::Mutex lock; sys::Thread worker; - Session& session; + Session session; Demux::QueuePtr queue; bool running; bool autoStop; @@ -67,7 +67,7 @@ class Dispatcher : public sys::Runnable bool isStopped(); public: - Dispatcher(Session& session, const std::string& queue = ""); + Dispatcher(const Session& session, const std::string& queue = ""); void start(); void run(); |