Author: fhanik
Date: Tue Mar 28 10:22:41 2006
New Revision: 389569
URL: http://svn.apache.org/viewcvs?rev=389569&view=rev
Log:
Added in a completion notification
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/ErrorHandler.java
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/ErrorHandler.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/ErrorHandler.java?rev=389569&r1=389568&r2=389569&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/ErrorHandler.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/ErrorHandler.java
Tue Mar 28 10:22:41 2006
@@ -25,6 +25,19 @@
*/
public interface ErrorHandler {
+ /**
+ * Invoked if the message is dispatched asynch, and an error occurs
+ * @param x Exception
+ * @param destination Member[]
+ * @param msg Serializable
+ */
public void handleError(Exception x, Member[] destination, Serializable
msg);
+
+ /**
+ * Invoked when the message has been sent.
+ * @param destination Member[]
+ * @param msg Serializable
+ */
+ public void handleCompletion(Member[] destination, Serializable msg);
}
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java?rev=389569&r1=389568&r2=389569&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
Tue Mar 28 10:22:41 2006
@@ -122,9 +122,18 @@
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();
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
