Hi Filip Thanks for the info. However, I don't see the documentation for the setters/getters you mention below? Also I'm having issues while debugging. When I hit a breakpoint in my code and while stepping thru code, I get DISAPPEARED/ADDED messages over and over on the other server? I would think the heartbeat is running in a separate thread for both send/receive? How to solve this, bump the heartbeat timeout?
TIA Mike -----Original Message----- From: Filip Hanik - Dev Lists [mailto:[EMAIL PROTECTED] Sent: October 3, 2008 2:51 PM To: Tomcat Users List Subject: Re: Basic Tribes Questions answers inline Mike Wannamaker wrote: > Hi, I am currently trying to use Tribes as the clustering layer on our server. > > My startup code looks like this. > > if(_tribesChannel == null) > { // nothing to do if already running > try > { > _tribesChannel = new GroupChannel(); > // must be done before start: > no need to use any properties, there are getters and setters for everything and they are all documented here http://tomcat.apache.org/tomcat-6.0-doc/config/cluster-channel.html > > _tribesChannel.getMembershipService().getProperties().put("mcastPort", > String.valueOf(_mainPort)); > > _tribesChannel.getMembershipService().getProperties().put("mcastAddress", > _multicastIPAddr); > not sure what you are trying to do in the code below. if you wanna set the port, then simply do it. the membership will pick it up automatically > if(_ancillaryPort > 0) > { > > _tribesChannel.getMembershipService().getProperties().put("tcpListenPort", > String.valueOf(_ancillaryPort)); > // hack alert: Default Tribes instantiation (Tomcat > 6.0.16) does not read value for "tcpListenPort" from properties. > // Therefore, set it directly > ChannelReceiver receiver = > _tribesChannel.getChannelReceiver(); > if(receiver.getPort() != _ancillaryPort) > { > if(receiver instanceof ReceiverBase) > { > ((ReceiverBase)receiver).setPort(_ancillaryPort); > } > } > } > > > _tribesChannel.addMembershipListener(_tribesMembershipListener); > _tribesChannel.addChannelListener(_tribesChannelListener); > _tribesChannel.start(CHANNEL_COMPONENTS); > } > catch(ChannelException ex) > { > try { _tribesChannel.stop(CHANNEL_COMPONENTS); } > catch(Throwable t) { /*gulp*/} > _tribesChannel = null; > throw new RuntimeException(ex); // todo, exception handling? > } > } > > My Question is that when I start Server #1, then Server #2, then unplug > Server #2 network cable, Server #1 gets the DISAPPEARED message but Server #2 > just keeps logging the message below. As I write this it's at attempt #120. > How do I get this to notify on Server #2 that Server #1 has DISAPPEARED or > can I set the number of attempts to a maximum number before notifying? > the message you are getting is cause the membership tries to recover. you can limit this, by doing setRecoveryEnabled(true|false); setRecoveryCounter(nr-of-times-to-try-recover) also, you haven't added in the TCP failure detector, which adds one more layer of protection see it in this default configuration http://tomcat.apache.org/tomcat-6.0-doc/cluster-howto.html you should still get the member disappeared error (eventually after the timeout), if you can supply a simple test case, I can try it out over here. best Filip > Also is there any other documentation for tribes, other than the limited docs > on the apache site? > > INFO: Done sleeping, membership established, start level:8 > Oct 3, 2008 1:12:44 PM > org.apache.catalina.tribes.transport.nio.NioReplicationTask run > WARNING: IOException in replication worker, unable to drain channel. > Probable cause: Keep alive socket closed[An existing connection was > forcibly closed by the remote host]. > Oct 3, 2008 1:12:44 PM > org.apache.catalina.tribes.membership.McastServiceImpl$SenderThread run > WARNING: Unable to send mcast message. > java.net.NoRouteToHostException: No route to host: Datagram send failed > at java.net.PlainDatagramSocketImpl.send(Native Method) > at java.net.DatagramSocket.send(DatagramSocket.java:612) > at > org.apache.catalina.tribes.membership.McastServiceImpl.send(McastServiceImpl.java:385) > at > org.apache.catalina.tribes.membership.McastServiceImpl$SenderThread.run(McastServiceImpl.java:445) > Oct 3, 2008 1:12:49 PM > org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread run > INFO: Tribes membership, running recovery thread, multicasting is not > functional. > Oct 3, 2008 1:12:49 PM > org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread > stopService > WARNING: Recovery thread failed to stop membership service. > java.net.NoRouteToHostException: No route to host: Datagram send failed > at java.net.PlainDatagramSocketImpl.send(Native Method) > at java.net.DatagramSocket.send(DatagramSocket.java:612) > at > org.apache.catalina.tribes.membership.McastServiceImpl.send(McastServiceImpl.java:385) > at > org.apache.catalina.tribes.membership.McastServiceImpl.stop(McastServiceImpl.java:299) > at > org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread.stopService(McastServiceImpl.java:480) > at > org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread.run(McastServiceImpl.java:504) > Oct 3, 2008 1:12:49 PM > org.apache.catalina.tribes.membership.McastServiceImpl setupSocket > INFO: Setting cluster mcast soTimeout to 500 > Oct 3, 2008 1:12:49 PM > org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread > startService > WARNING: Recovery thread failed to start membership service. > java.net.SocketException: error setting options > at java.net.PlainDatagramSocketImpl.join(Native Method) > at > java.net.PlainDatagramSocketImpl.join(PlainDatagramSocketImpl.java:172) > at java.net.MulticastSocket.joinGroup(MulticastSocket.java:276) > at > org.apache.catalina.tribes.membership.McastServiceImpl.start(McastServiceImpl.java:233) > at > org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread.startService(McastServiceImpl.java:490) > at > org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread.run(McastServiceImpl.java:504) > Oct 3, 2008 1:12:49 PM > org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread run > INFO: Recovery attempt 1 failed, trying again in 5000 seconds > > --------------------------------------------------------------------- To start a new topic, e-mail: users@tomcat.apache.org To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
