summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionManager.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/SessionManager.cpp')
-rw-r--r--cpp/src/qpid/broker/SessionManager.cpp9
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