Author: fhanik
Date: Fri Mar 10 16:59:55 2006
New Revision: 384975

URL: http://svn.apache.org/viewcvs?rev=384975&view=rev
Log:
You can't send null, always specify the destination

Modified:
    
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java
    
tomcat/container/tc5.5.x/modules/ha/src/share/org/apache/catalina/ha/tcp/SimpleTcpCluster.java

Modified: 
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java
URL: 
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java?rev=384975&r1=384974&r2=384975&view=diff
==============================================================================
--- 
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java
 (original)
+++ 
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java
 Fri Mar 10 16:59:55 2006
@@ -136,7 +136,7 @@
                         if (debug) {
                             printArray(msg.getMessage());
                         }
-                        channel.send(null, msg);
+                        channel.send(channel.getMembers(), msg);
                         if ( pause > 0 ) {
                             if ( debug) System.out.println("Pausing sender for 
"+pause+" ms.");
                             Thread.sleep(pause);

Modified: 
tomcat/container/tc5.5.x/modules/ha/src/share/org/apache/catalina/ha/tcp/SimpleTcpCluster.java
URL: 
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/ha/src/share/org/apache/catalina/ha/tcp/SimpleTcpCluster.java?rev=384975&r1=384974&r2=384975&view=diff
==============================================================================
--- 
tomcat/container/tc5.5.x/modules/ha/src/share/org/apache/catalina/ha/tcp/SimpleTcpCluster.java
 (original)
+++ 
tomcat/container/tc5.5.x/modules/ha/src/share/org/apache/catalina/ha/tcp/SimpleTcpCluster.java
 Fri Mar 10 16:59:55 2006
@@ -783,7 +783,7 @@
                 } else
                     log.error("Unable to send message to local member " + msg);
             } else {
-                channel.send(null,msg);
+                channel.send(channel.getMembers(),msg);
             }
         } catch (Exception x) {
             log.error("Unable to send message through cluster sender.", x);



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]

Reply via email to