tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From p...@apache.org
Subject svn commit: r525780 - /tomcat/container/tc5.5.x/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java
Date Thu, 05 Apr 2007 09:34:28 GMT
Author: pero
Date: Thu Apr  5 02:34:27 2007
New Revision: 525780

URL: http://svn.apache.org/viewvc?view=rev&rev=525780
Log:
Log error as sender is no a regsiterd member.

Modified:
    tomcat/container/tc5.5.x/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java

Modified: tomcat/container/tc5.5.x/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java
URL: http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java?view=diff&rev=525780&r1=525779&r2=525780
==============================================================================
--- tomcat/container/tc5.5.x/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java
(original)
+++ tomcat/container/tc5.5.x/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java
Thu Apr  5 02:34:27 2007
@@ -431,7 +431,21 @@
             ClusterData data = serialize(message);
             String key = getKey(member);
             IDataSender sender = (IDataSender) map.get(key);
-            sendMessageData(data, sender);
+            if(sender == null) {
+                if (log.isErrorEnabled() ) {
+                    IDataSender[] senders = getSenders();
+                    StringBuffer senderInfo = new StringBuffer() ;
+                    for (int i = 0; i < senders.length; i++) {
+                        IDataSender sender1 = senders[i];
+                        senderInfo.append(sender1.toString());
+                        if(i-1 < senders.length)
+                            senderInfo.append(",") ;
+                    }                     
+                    log.error("Unable to send replicated message to member ["+
+                            member+"], has only senders for [" + senderInfo + "]");
+                }
+            } else
+                sendMessageData(data, sender);
         } finally {
             if (doTransmitterProcessingStats) {
                 addProcessingStats(time);



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org


Mime
View raw message