CVS update: JGroups/src/org/jgroups/demos ProgrammaticChat.java

  User: belaban 
  Date: 10/10/20 11:35:10

  Modified:    src/org/jgroups/demos ProgrammaticChat.java
  Log:
  ns
  
  Revision  Changes    Path
  1.2       +15 -6     JGroups/src/org/jgroups/demos/ProgrammaticChat.java
  
  Index: ProgrammaticChat.java
  ===================================================================
  RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/demos/ProgrammaticChat.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- ProgrammaticChat.java	6 Oct 2010 09:46:31 -0000	1.1
  +++ ProgrammaticChat.java	20 Oct 2010 11:35:10 -0000	1.2
  @@ -15,18 +15,27 @@
   
   /**
    * @author Bela Ban
  - * @version $Id: ProgrammaticChat.java,v 1.1 2010/10/06 09:46:31 belaban Exp $
  + * @version $Id: ProgrammaticChat.java,v 1.2 2010/10/20 11:35:10 belaban Exp $
    */
   public class ProgrammaticChat {
   
       public static void main(String[] args) throws Exception {
           JChannel ch=new JChannel(false);
           ProtocolStack stack=ch.createProtocolStack();
  -        stack.addProtocol(new UDP().setValue("bind_addr", InetAddress.getByName("192.168.1.5"))).
  -                addProtocol(new PING()).addProtocol(new MERGE2()).addProtocol(new FD_SOCK()).
  -                addProtocol(new FD_ALL()).addProtocol(new VERIFY_SUSPECT()).addProtocol(new BARRIER()).
  -                addProtocol(new NAKACK()).addProtocol(new UNICAST2()).addProtocol(new STABLE()).
  -                addProtocol(new GMS()).addProtocol(new UFC()).addProtocol(new MFC()).addProtocol(new FRAG2());
  +        stack.addProtocol(new UDP().setValue("bind_addr", InetAddress.getByName("192.168.1.5")))
  +                .addProtocol(new PING())
  +                .addProtocol(new MERGE2())
  +                .addProtocol(new FD_SOCK())
  +                .addProtocol(new FD_ALL().setValue("timeout", 12000).setValue("interval", 3000))
  +                .addProtocol(new VERIFY_SUSPECT())
  +                .addProtocol(new BARRIER())
  +                .addProtocol(new NAKACK())
  +                .addProtocol(new UNICAST2())
  +                .addProtocol(new STABLE())
  +                .addProtocol(new GMS())
  +                .addProtocol(new UFC())
  +                .addProtocol(new MFC())
  +                .addProtocol(new FRAG2());
           stack.init();
   
           ch.setReceiver(new ReceiverAdapter() {
  
  
  

------------------------------------------------------------------------------
Download new Adobe(R) Flash(R) Builder(TM) 4
The new Adobe(R) Flex(R) 4 and Flash(R) Builder(TM) 4 (formerly 
Flex(R) Builder(TM)) enable the development of rich applications that run
across multiple browsers and platforms. Download your free trials today!
http://p.sf.net/sfu/adobe-dev2dev