From 1fd398c1c0b78ce48d3b540698cfbf085e5ff8dd Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Tue, 29 Jan 2008 20:39:26 +0000 Subject: Added Observer to SessionManager for cluster use. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@616511 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/SessionManager.cpp | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'cpp/src/qpid/broker/SessionManager.cpp') diff --git a/cpp/src/qpid/broker/SessionManager.cpp b/cpp/src/qpid/broker/SessionManager.cpp index 1d5f9ebada..aadb2b9004 100644 --- a/cpp/src/qpid/broker/SessionManager.cpp +++ b/cpp/src/qpid/broker/SessionManager.cpp @@ -50,6 +50,8 @@ std::auto_ptr SessionManager::open( std::auto_ptr session( new SessionState(*this, h, timeout_, ack)); active.insert(session->getId()); + for_each(observers.begin(), observers.end(), + boost::bind(&Observer::opened, _1,boost::ref(*session))); return session; } @@ -102,4 +104,8 @@ void SessionManager::eraseExpired() { } } +void SessionManager::add(const intrusive_ptr& o) { + observers.push_back(o); +} + }} // namespace qpid::broker -- cgit v1.2.1