remove retry from the API.

git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@1069530 13f79535-47bb-0310-9956-ffa450edef68

diff --git a/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java b/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java
index d6e95cb..e24e484 100644 (file)
--- a/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java
+++ b/java/org/apache/catalina/tribes/group/ExtendedRpcCallback.java
@@ -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

diff --git a/java/org/apache/catalina/tribes/group/RpcChannel.java b/java/org/apache/catalina/tribes/group/RpcChannel.java
index b33214a..39c4c04 100644 (file)
--- a/java/org/apache/catalina/tribes/group/RpcChannel.java
+++ b/java/org/apache/catalina/tribes/group/RpcChannel.java
@@ -159,9 +159,8 @@ public class RpcChannel implements ChannelListener{
                 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);
                 }
             }