diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2007-01-17 16:23:47 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2007-01-17 16:23:47 +0000 |
| commit | 2fec3c4f9ce8ba227f4c53d251aa6d11c7772a09 (patch) | |
| tree | 988963431ec0b059e0a0a7626669971b6545dd88 /java/client | |
| parent | bbafa7f994e1d5592e984414e915bdc76a445c2e (diff) | |
| download | qpid-python-2fec3c4f9ce8ba227f4c53d251aa6d11c7772a09.tar.gz | |
added error handling and resolved compilation errors
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497063 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java | 4 | ||||
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java index 44be521197..edef6c57c2 100644 --- a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java @@ -403,12 +403,12 @@ public class AMQProtocolHandler extends IoHandlerAdapter _protocolSession.writeFrame(frame, wait); } - public long writeRequest(int channelNum, AMQMethodBody methodBody) + public long writeRequest(int channelNum, AMQMethodBody methodBody) throws AMQException { return _protocolSession.writeRequest(channelNum, methodBody, _protocolSession.getStateManager()); } - public void writeResponse(int channelNum, long requestId, AMQMethodBody methodBody) + public void writeResponse(int channelNum, long requestId, AMQMethodBody methodBody) throws AMQException { _protocolSession.writeResponse(channelNum, requestId, methodBody); } diff --git a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java index ef738058d4..1a739feb35 100644 --- a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java @@ -334,7 +334,7 @@ public class AMQProtocolSession implements AMQProtocolWriter, ProtocolVersionLis RequestManager requestManager = (RequestManager)_channelId2RequestMgrMap.get(channelNum); if (requestManager == null) throw new AMQException("Unable to find RequestManager for channel " + channelNum); - requestManager.sendRequest(methodBody, methodListener); + return requestManager.sendRequest(methodBody, methodListener); } public void writeResponse(int channelNum, long requestId, AMQMethodBody methodBody) |