diff options
Diffstat (limited to 'java')
| -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) |