Author: fhanik
Date: Thu Feb 10 18:59:08 2011
New Revision: 1069530
URL: http://svn.apache.org/viewvc?rev=1069530&view=rev
Log:
remove retry from the API.
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java
tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java?rev=1069530&r1=1069529&r2=1069530&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java
(original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java
Thu Feb 10 18:59:08 2011
@@ -21,24 +21,23 @@ import java.io.Serializable;
import org.apache.catalina.tribes.Member;
/**
* Extension to the {@link RpcCallback} interface. Allows a RPC messenger to
get a confirmation if the reply
- * was sent successfully to the original sender.
+ * was sent successfully to the original sender.
* @author fhanik
*
*/
public interface ExtendedRpcCallback extends RpcCallback {
/**
- *
+ * The reply failed.
* @param request - the original message that requested the reply
* @param response - the reply message to the original message
* @param sender - the sender requested that reply
* @param reason - the reason the reply failed
- * @return true if the callback would like to reattempt the reply, false
otherwise
*/
- public boolean replyFailed(Serializable request, Serializable response,
Member sender, Exception reason);
+ public void replyFailed(Serializable request, Serializable response,
Member sender, Exception reason);
/**
- *
+ * The reply succeeded
* @param request - the original message that requested the reply
* @param response - the reply message to the original message
* @param sender - the sender requested that reply
Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java?rev=1069530&r1=1069529&r2=1069530&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
(original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java Thu Feb
10 18:59:08 2011
@@ -159,9 +159,8 @@ public class RpcChannel implements Chann
finished = true;
}catch ( Exception x ) {
if (excallback != null && !asyncReply) {
- finished = !excallback.replyFailed(rmsg.message, reply,
sender, x);
+ excallback.replyFailed(rmsg.message, reply, sender, x);
} else {
- finished = true;
log.error("Unable to send back reply in RpcChannel.",x);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
