diff options
Diffstat (limited to 'cpp/lib/common/framing/BodyHandler.cpp')
-rw-r--r-- | cpp/lib/common/framing/BodyHandler.cpp | 19 |
1 files changed, 0 insertions, 19 deletions
diff --git a/cpp/lib/common/framing/BodyHandler.cpp b/cpp/lib/common/framing/BodyHandler.cpp index 72ba82468f..5dd0c0c23d 100644 --- a/cpp/lib/common/framing/BodyHandler.cpp +++ b/cpp/lib/common/framing/BodyHandler.cpp @@ -58,22 +58,3 @@ void BodyHandler::handleBody(shared_ptr<AMQBody> body) { } } -void BodyHandler::handleRequest(AMQRequestBody::shared_ptr request) { - responder.received(request->getData()); - handleMethod(request); -} - -void BodyHandler::handleResponse(AMQResponseBody::shared_ptr response) { - handleMethod(response); - requester.processed(response->getData()); -} - -void BodyHandler::assertChannelZero(u_int16_t id) { - if (id != 0) - throw ConnectionException(504, "Invalid channel id, not 0"); -} - -void BodyHandler::assertChannelNonZero(u_int16_t id) { - if (id == 0) - throw ConnectionException(504, "Invalid channel id 0"); -} |