diff options
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/RequestManager.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/RequestManager.java b/java/common/src/main/java/org/apache/qpid/framing/RequestManager.java index cd63a60c04..836c4ad985 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/RequestManager.java +++ b/java/common/src/main/java/org/apache/qpid/framing/RequestManager.java @@ -75,8 +75,6 @@ public class RequestManager long requestId = getNextRequestId(); // Get new request ID AMQFrame requestFrame = AMQRequestBody.createAMQFrame(channel, requestId, lastProcessedResponseId, requestMethodBody); - requestSentMap.put(requestId, methodListener); - protocolWriter.writeFrame(requestFrame); if (logger.isDebugEnabled()) { logger.debug((serverFlag ? "SRV[" : "CLI[") + connectionId + "," + channel + @@ -84,6 +82,8 @@ public class RequestManager } //System.out.println((serverFlag ? "SRV[" : "CLI[") + connectionId + "," + channel + // "] TX REQ: Req[" + requestId + " " + lastProcessedResponseId + "]; " + requestMethodBody); + requestSentMap.put(requestId, methodListener); + protocolWriter.writeFrame(requestFrame); return requestId; } |