From 78c5b9d3bb77f892c787848850a1b0208b850187 Mon Sep 17 00:00:00 2001
From: fhanik <fhanik@13f79535-47bb-0310-9956-ffa450edef68>
Date: Wed, 22 Aug 2007 14:43:08 +0000
Subject: [PATCH] Added example on how you can name nodes with existing system

git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@568631 13f79535-47bb-0310-9956-ffa450edef68
---
 .../tribes/test/membership/NamedNodes.java         | 54 ++++++++++++++++++++++
 1 file changed, 54 insertions(+)
 create mode 100644 test/org/apache/catalina/tribes/test/membership/NamedNodes.java

diff --git a/test/org/apache/catalina/tribes/test/membership/NamedNodes.java b/test/org/apache/catalina/tribes/test/membership/NamedNodes.java
new file mode 100644
index 000000000..a80e7613d
--- /dev/null
+++ b/test/org/apache/catalina/tribes/test/membership/NamedNodes.java
@@ -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
-- 
2.11.0