Author: rajith
Date: Wed Jan 17 08:23:47 2007
New Revision: 497063
URL: http://svn.apache.org/viewvc?view=rev&rev=497063
Log:
added error handling and resolved compilation errors
Modified:
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
Modified:
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java?view=diff&rev=497063&r1=497062&r2=497063
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
(original)
+++
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Wed Jan 17 08:23:47 2007
@@ -403,12 +403,12 @@
_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);
}
Modified:
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java?view=diff&rev=497063&r1=497062&r2=497063
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
(original)
+++
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
Wed Jan 17 08:23:47 2007
@@ -334,7 +334,7 @@
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)
