EXAMPLE


1   // $Id: EXAMPLE.java,v 1.3 2004/09/23 16:29:41 belaban Exp $
2   
3   package org.jgroups.protocols;
4   
5   import org.jgroups.Event;
6   import org.jgroups.Message;
7   import org.jgroups.View;
8   import org.jgroups.stack.Protocol;
9   
10  import java.io.Serializable  ;
11  import java.util.Vector  ;
12  
13  
14  
15  class ExampleHeader implements Serializable   {
16      // your variables
17  
18      public ExampleHeader() {
19      }
20  
21      public String   toString() {
22      return "[EXAMPLE: <variables> ]";
23      }
24  }
25  
26  
27  /**
28   * Example of a protocol layer. Contains no real functionality, can be used as a template.
29   */
30  
31  public class EXAMPLE extends Protocol {
32      final Vector     members=new Vector  ();
33  
34      /** All protocol names have to be unique ! */
35      public String    getName() {return "EXAMPLE";}
36  
37  
38  
39  
40  
41      /** Just remove if you don't need to reset any state */
42      public void reset() {}
43  
44  
45  
46  
47      public void up(Event evt) {
48      Message msg;
49  
50      switch(evt.getType()) {
51  
52      case Event.MSG:
53          msg=(Message)evt.getArg();
54          // Do something with the event, e.g. extract the message and remove a header.
55          // Optionally pass up
56          break;
57      }
58  
59      passUp(evt);            // Pass up to the layer above us
60      }
61  
62  
63  
64  
65  
66      public void down(Event evt) {
67      Message msg;
68  
69      switch(evt.getType()) {
70      case Event.TMP_VIEW:
71      case Event.VIEW_CHANGE:
72          Vector   new_members=((View)evt.getArg()).getMembers();
73          synchronized(members) {
74          members.removeAllElements();
75          if(new_members != null && new_members.size() > 0)
76              for(int i=0; i < new_members.size(); i++)
77              members.addElement(new_members.elementAt(i));
78          }
79          passDown(evt);
80          break;
81  
82      case Event.MSG:
83          msg=(Message)evt.getArg();
84          // Do something with the event, e.g. add a header to the message
85          // Optionally pass down
86          break;
87      }
88  
89      passDown(evt);          // Pass on to the layer below us
90      }
91  
92  
93  
94  }
95
A to Z: JavaDoc & Examples Daily Java News & Articles Open Source Projects Open Source Codes Free Computer Books Remove Frame
Free Books Free Magazines
Popular Tags