You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by kf...@apache.org on 2018/05/29 06:45:47 UTC
svn commit: r1832430 -
/tomcat/trunk/java/org/apache/catalina/ha/tcp/SimpleTcpCluster.java
Author: kfujino
Date: Tue May 29 06:45:46 2018
New Revision: 1832430
URL: http://svn.apache.org/viewvc?rev=1832430&view=rev
Log:
Simplify codes.
remove duplicate codes.
Modified:
tomcat/trunk/java/org/apache/catalina/ha/tcp/SimpleTcpCluster.java
Modified: tomcat/trunk/java/org/apache/catalina/ha/tcp/SimpleTcpCluster.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/ha/tcp/SimpleTcpCluster.java?rev=1832430&r1=1832429&r2=1832430&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/ha/tcp/SimpleTcpCluster.java (original)
+++ tomcat/trunk/java/org/apache/catalina/ha/tcp/SimpleTcpCluster.java Tue May 29 06:45:46 2018
@@ -680,24 +680,7 @@ public class SimpleTcpCluster extends Li
*/
@Override
public void send(ClusterMessage msg, Member dest) {
- try {
- msg.setAddress(getLocalMember());
- int sendOptions = channelSendOptions;
- if (dest != null) {
- if (!getLocalMember().equals(dest)) {
- channel.send(new Member[] {dest}, msg, sendOptions);
- } else
- log.error(sm.getString("simpleTcpCluster.unableSend.localMember", msg));
- } else {
- Member[] destmembers = channel.getMembers();
- if (destmembers.length>0)
- channel.send(destmembers,msg, sendOptions);
- else if (log.isDebugEnabled())
- log.debug("No members in cluster, ignoring message:"+msg);
- }
- } catch (Exception x) {
- log.error(sm.getString("simpleTcpCluster.sendFailed"), x);
- }
+ send(msg, dest, this.channelSendOptions);
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org