Diff of /tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java

Parent Directory | Revision Log | Patch

--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java	2006/03/28 18:18:58	389568
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java	2006/03/28 18:22:41	389569
@@ -122,9 +122,18 @@ public class MessageDispatchInterceptor
                 Member[] destination = link.getDestination();
                 try {
                     super.sendMessage(destination,msg,null);
+                    try {
+                        if ( link.getHandler() != null ) link.getHandler().handleCompletion(destination,msg); 
+                    } catch ( Exception ex ) {
+                        log.error("Unable to report back completed message.",ex);
+                    }
                 } catch ( Exception x ) {
                     if ( log.isDebugEnabled() ) log.debug("Error while processing async message.",x);
-                    if ( link.getHandler() != null ) link.getHandler().handleError(x,destination,msg);
+                    try {
+                        if (link.getHandler() != null) link.getHandler().handleError(x, destination, msg);
+                    } catch ( Exception ex ) {
+                        log.error("Unable to report back error message.",ex);
+                    }
                 } finally {
                     currentSize.addAndGet(-msg.getMessage().getLength());
                     link = link.next();