Author: fhanik Date: Wed Aug 22 07:43:08 2007 New Revision: 568631 URL: http://svn.apache.org/viewvc?rev=568631&view=rev Log: Added example on how you can name nodes with existing system
Added: tomcat/trunk/test/org/apache/catalina/tribes/test/membership/NamedNodes.java Added: tomcat/trunk/test/org/apache/catalina/tribes/test/membership/NamedNodes.java URL: http://svn.apache.org/viewvc/tomcat/trunk/test/org/apache/catalina/tribes/test/membership/NamedNodes.java?rev=568631&view=auto ============================================================================== --- tomcat/trunk/test/org/apache/catalina/tribes/test/membership/NamedNodes.java (added) +++ tomcat/trunk/test/org/apache/catalina/tribes/test/membership/NamedNodes.java Wed Aug 22 07:43:08 2007 @@ -0,0 +1,54 @@ +package org.apache.catalina.tribes.test.membership; + +import org.apache.catalina.tribes.group.GroupChannel; +import org.apache.catalina.tribes.membership.MemberImpl; +import org.apache.catalina.tribes.MembershipListener; +import org.apache.catalina.tribes.Member; +import org.apache.catalina.tribes.Channel; + +public class NamedNodes implements MembershipListener{ + + public void namedNodes() throws Exception { + GroupChannel[] channels = new GroupChannel[3]; + for (int i=0; i<channels.length; i++) { + channels[i] = new GroupChannel(); + //start the receiver, so that we can identify the local member + channels[i].start(Channel.SND_RX_SEQ); + MemberImpl member = (MemberImpl)channels[i].getLocalMember(false); + String name = "Member Nr-"+(i+1); + member.setPayload(name.getBytes("ASCII")); + channels[i].addMembershipListener(this); + channels[i].start(Channel.SND_TX_SEQ|Channel.MBR_RX_SEQ|Channel.MBR_TX_SEQ); + } + Thread.sleep(5000); + for (int i=0; i<channels.length; i++) { + channels[i].stop(Channel.DEFAULT); + Thread.sleep(1000); + } + } + + public static void main(String[] args) throws Exception { + NamedNodes nm = new NamedNodes(); + nm.namedNodes(); + } + + public void memberAdded(Member member) { + try { + String name = new String(member.getPayload(), "ASCII"); + System.out.println("Node with name:"+name+" just joined"); + }catch ( Exception x ) { + x.printStackTrace(); + } + } + + public void memberDisappeared(Member member) { + try { + String name = new String(member.getPayload(), "ASCII"); + System.out.println("Node with name:"+name+" just left"); + }catch ( Exception x ) { + x.printStackTrace(); + } + + } + +} \ No newline at end of file --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]