diff options
Diffstat (limited to 'cpp/src/qpid/broker/SessionManager.cpp')
-rw-r--r-- | cpp/src/qpid/broker/SessionManager.cpp | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/cpp/src/qpid/broker/SessionManager.cpp b/cpp/src/qpid/broker/SessionManager.cpp index 69ef29c3eb..e7190fdae6 100644 --- a/cpp/src/qpid/broker/SessionManager.cpp +++ b/cpp/src/qpid/broker/SessionManager.cpp @@ -55,11 +55,8 @@ std::auto_ptr<SessionState> SessionManager::attach(SessionHandler& h, const Ses throw SessionBusyException(QPID_MSG("Session already attached: " << id)); Detached::iterator i = std::find(detached.begin(), detached.end(), id); std::auto_ptr<SessionState> state; - if (i == detached.end()) { + if (i == detached.end()) state.reset(new SessionState(broker, h, id, config)); - for_each(observers.begin(), observers.end(), - boost::bind(&Observer::opened, _1,boost::ref(*state))); - } else { state.reset(detached.release(i).release()); state->attach(h); @@ -99,8 +96,4 @@ void SessionManager::eraseExpired() { } } -void SessionManager::add(const intrusive_ptr<Observer>& o) { - observers.push_back(o); -} - }} // namespace qpid::broker |