diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-01-30 16:40:41 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-01-30 16:40:41 +0000 |
| commit | 0a0d784009eadd3d7679a8cb6a73258562616af7 (patch) | |
| tree | d9ff386f7ec63c4d75b11999840a4911459c7fc1 /java/common/src | |
| parent | db6f152f26ae8de79b1aec55a16af401b97548d9 (diff) | |
| download | qpid-python-0a0d784009eadd3d7679a8cb6a73258562616af7.tar.gz | |
Separated the errata in the XML spec file and put them into a file amqp-errara.0-9.xml. Added this file to the codegen. Fixed minor codegen bug in which fields in merged classes have repeating ordinal numbers. Added missing mandatory field to Message.Transger in the new errata file.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501456 13f79535-47bb-0310-9956-ffa450edef68
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; } |