From 2fec3c4f9ce8ba227f4c53d251aa6d11c7772a09 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Wed, 17 Jan 2007 16:23:47 +0000 Subject: 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 --- .../main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java | 4 ++-- .../main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) (limited to 'java/client') 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) -- cgit v1.2.1