r1102@fuschia: andrew | 2007-02-09 00:52:04 +0000

 Got ack working for the non batched case
 Small tidy up in broker Channel


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@505108 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 2 deletions

diff --git a/cpp/lib/common/framing/ChannelAdapter.cpp b/cpp/lib/common/framing/ChannelAdapter.cpp
index 149c8144b4..53ab30faa0 100644
--- a/cpp/lib/common/framing/ChannelAdapter.cpp
+++ b/cpp/lib/common/framing/ChannelAdapter.cpp
@@ -55,7 +55,9 @@ void ChannelAdapter::send(AMQBody::shared_ptr body) {
 
 void ChannelAdapter::handleRequest(AMQRequestBody::shared_ptr request) {
     assertMethodOk(*request);
-    responder.received(request->getData());
+    AMQRequestBody::Data& requestData = request->getData();
+    responder.received(requestData);
+    requestInProgress = requestData.requestId;
     handleMethodInContext(request, MethodContext(this, request));
 }
 
@@ -63,7 +65,10 @@ void ChannelAdapter::handleResponse(AMQResponseBody::shared_ptr response) {
     assertMethodOk(*response);
     // TODO aconway 2007-01-30: Consider a response handled on receipt.
     // Review - any cases where this is not the case?
-    requester.processed(response->getData());
+    AMQResponseBody::Data& responseData = response->getData();
+    requester.processed(responseData);
+    // For a response this is taken to be the request being responded to (for convenience)
+    requestInProgress = responseData.requestId;
     handleMethod(response);
 }