Author: fhanik
Date: Tue Apr 25 07:13:21 2006
New Revision: 396895
URL: http://svn.apache.org/viewcvs?rev=396895&view=rev
Log:
Added a NO_REPLY to RPC messages
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java?rev=396895&r1=396894&r2=396895&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java
Tue Apr 25 07:13:21 2006
@@ -41,6 +41,7 @@
public static final int FIRST_REPLY = 1;
public static final int MAJORITY_REPLY = 2;
public static final int ALL_REPLY = 3;
+ public static final int NO_REPLY = 4;
private Channel channel;
private RpcCallback callback;
@@ -90,7 +91,7 @@
responseMap.put(key, collector);
RpcMessage rmsg = new RpcMessage(rpcId, key.id, message);
channel.send(destination, rmsg, channelOptions);
- collector.wait(timeout);
+ if ( rpcOptions != NO_REPLY) collector.wait(timeout);
}
} catch ( InterruptedException ix ) {
Thread.currentThread().interrupted();
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
