summaryrefslogtreecommitdiff
path: root/cpp/lib/common
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-01-15 18:28:29 +0000
committerAlan Conway <aconway@apache.org>2007-01-15 18:28:29 +0000
commit87d97b5bcc5b7fe44cfc71ce28ccfeae1d9b2274 (patch)
tree03929353228d063bf8892d6c57d4bf46fa467ddd /cpp/lib/common
parentfa15e6d52022cc1576b19e3caaecf66260c1923e (diff)
downloadqpid-python-87d97b5bcc5b7fe44cfc71ce28ccfeae1d9b2274.tar.gz
* Refactor: Moved major broker components (exchanges, queues etc.) from
class SessionHandlerImplFactory to more logical class Broker. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496425 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/lib/common')
-rw-r--r--cpp/lib/common/framing/Responder.cpp4
-rw-r--r--cpp/lib/common/framing/Responder.h2
2 files changed, 3 insertions, 3 deletions
diff --git a/cpp/lib/common/framing/Responder.cpp b/cpp/lib/common/framing/Responder.cpp
index efe3609c7b..1fbbfb8542 100644
--- a/cpp/lib/common/framing/Responder.cpp
+++ b/cpp/lib/common/framing/Responder.cpp
@@ -30,9 +30,9 @@ void Responder::received(const AMQRequestBody::Data& request) {
responseMark = request.responseMark;
}
-void Responder::sending(AMQResponseBody::Data& response, RequestId toRequest) {
+void Responder::sending(AMQResponseBody::Data& response) {
response.responseId = ++lastId;
- response.requestId = toRequest;
+ // response.requestId should have been set by caller.
response.batchOffset = 0;
}
diff --git a/cpp/lib/common/framing/Responder.h b/cpp/lib/common/framing/Responder.h
index a11967acc1..0e1785256b 100644
--- a/cpp/lib/common/framing/Responder.h
+++ b/cpp/lib/common/framing/Responder.h
@@ -40,7 +40,7 @@ class Responder
void received(const AMQRequestBody::Data& request);
/** Called before sending a response to set respose data. */
- void sending(AMQResponseBody::Data& response, RequestId toRequest);
+ void sending(AMQResponseBody::Data& response);
/** Get the ID of the highest response acknowledged by the peer. */
ResponseId getResponseMark() { return responseMark; }