diff options
author | Alan Conway <aconway@apache.org> | 2007-01-12 18:24:13 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-01-12 18:24:13 +0000 |
commit | a2f603a03b5a6451139d4fcb22fd6e34f55c11e5 (patch) | |
tree | 82bb1d533568e3d40f060f00cf7d70474dffee2c /cpp/lib/common/framing/BodyHandler.cpp | |
parent | 482ff88ac8fcaf14207db6e23d3b9981365dfd62 (diff) | |
download | qpid-python-a2f603a03b5a6451139d4fcb22fd6e34f55c11e5.tar.gz |
Use amqp 0-9 request/response framing in broker and client.
Updated: framing, client, broker, generated code.
The new request/response data (request-id etc.) is not yet being used,
we are simply running the old Basic protocol over request/response frames.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495679 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/lib/common/framing/BodyHandler.cpp')
-rw-r--r-- | cpp/lib/common/framing/BodyHandler.cpp | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/cpp/lib/common/framing/BodyHandler.cpp b/cpp/lib/common/framing/BodyHandler.cpp index ae4ff25bbe..1f761bf3f1 100644 --- a/cpp/lib/common/framing/BodyHandler.cpp +++ b/cpp/lib/common/framing/BodyHandler.cpp @@ -30,24 +30,25 @@ void BodyHandler::handleBody(const AMQBody::shared_ptr& body){ switch(body->type()) { - - case METHOD_BODY: + case METHOD_BODY: + case REQUEST_BODY: + case RESPONSE_BODY: handleMethod(dynamic_pointer_cast<AMQMethodBody, AMQBody>(body)); break; - case HEADER_BODY: + case HEADER_BODY: handleHeader(dynamic_pointer_cast<AMQHeaderBody, AMQBody>(body)); break; - case CONTENT_BODY: + case CONTENT_BODY: handleContent(dynamic_pointer_cast<AMQContentBody, AMQBody>(body)); break; - case HEARTBEAT_BODY: + case HEARTBEAT_BODY: handleHeartbeat(dynamic_pointer_cast<AMQHeartbeatBody, AMQBody>(body)); break; - default: + default: throw UnknownBodyType(body->type()); } |