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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
