diff options
Diffstat (limited to 'cpp/lib/broker/SessionHandlerImpl.cpp')
-rw-r--r-- | cpp/lib/broker/SessionHandlerImpl.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/lib/broker/SessionHandlerImpl.cpp b/cpp/lib/broker/SessionHandlerImpl.cpp index d0971c4fae..3110c7ca3d 100644 --- a/cpp/lib/broker/SessionHandlerImpl.cpp +++ b/cpp/lib/broker/SessionHandlerImpl.cpp @@ -95,7 +95,9 @@ void SessionHandlerImpl::received(qpid::framing::AMQFrame* frame){ switch(body->type()) { - case METHOD_BODY: + case REQUEST_BODY: + case RESPONSE_BODY: + case METHOD_BODY: method = dynamic_pointer_cast<AMQMethodBody, AMQBody>(body); try{ method->invoke(*this, channel); |