diff options
Diffstat (limited to 'cpp/src/qpid/broker/Connection.cpp')
-rw-r--r-- | cpp/src/qpid/broker/Connection.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/Connection.cpp b/cpp/src/qpid/broker/Connection.cpp index 825ce4978c..ec6fd6ece7 100644 --- a/cpp/src/qpid/broker/Connection.cpp +++ b/cpp/src/qpid/broker/Connection.cpp @@ -52,7 +52,7 @@ void Connection::received(framing::AMQFrame& frame){ if (frame.getChannel() == 0) { adapter.handle(frame); } else { - SessionAdapter sa = getChannel(frame.getChannel()); + SessionHandler sa = getChannel(frame.getChannel()); sa.in(frame); } } @@ -94,8 +94,8 @@ void Connection::closeChannel(uint16_t id) { if (i != channels.end()) channels.erase(i); } -SessionAdapter Connection::getChannel(ChannelId id) { - boost::optional<SessionAdapter>& ch = channels[id]; +SessionHandler Connection::getChannel(ChannelId id) { + boost::optional<SessionHandler>& ch = channels[id]; if (!ch) { ch = boost::in_place(boost::ref(*this), id); } |