Package org.jgroups.demos

Class RelayDemo

  • All Implemented Interfaces:
    Receiver
    public class RelayDemo
extends java.lang.Object
implements Receiver
    Demos RELAY. Create 2 *separate* clusters with RELAY as top protocol. Each RELAY has bridge_props="tcp.xml" (tcp.xml needs to be present). Then start 2 instances in the first cluster and 2 instances in the second cluster. They should find each other, and typing in a window should send the text to everyone, plus we should get 4 responses.
    Author:
    Bela Ban

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected JChannel ch  
      protected RELAY relay  
      protected static java.lang.String SENDTO  
      protected static java.lang.String SITE_MASTERS  

    • Constructor Summary

      Constructors 
      Constructor Description
      RelayDemo()  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void eventLoop​(JChannel ch)  
      protected static void help()  
      static void main​(java.lang.String[] args)  
      protected java.lang.String printTopo​(java.lang.String line, java.lang.String command, boolean refresh)  
      protected boolean process​(java.lang.String line)  
      void receive​(Message msg)
      Called when a message is received.
      protected void sendTo​(java.lang.String line)  
      protected void start​(java.lang.String props, java.lang.String name, boolean print_route_status, boolean nohup, boolean use_view_handler)  
      void viewAccepted​(View new_view)
      Called when a change in membership has occurred.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • RelayDemo

        public RelayDemo()

    • Method Detail

      • main

        public static void main​(java.lang.String[] args)
                 throws java.lang.Exception
        Throws:
        java.lang.Exception

      • receive

        public void receive​(Message msg)
        Description copied from interface: Receiver
        Called when a message is received.
        Specified by:
        receive in interface Receiver
        Parameters:
        msg - The message

      • viewAccepted

        public void viewAccepted​(View new_view)
        Description copied from interface: Receiver
        Called when a change in membership has occurred. No long running actions, sending of messages or anything that could block should be done in this callback. If some long running action needs to be performed, it should be done in a separate thread.
        Note that on reception of the first view (a new member just joined), the channel will not yet be in the connected state. This only happens when JChannel.connect(String) returns.
        Specified by:
        viewAccepted in interface Receiver

      • start

        protected void start​(java.lang.String props,
                     java.lang.String name,
                     boolean print_route_status,
                     boolean nohup,
                     boolean use_view_handler)
              throws java.lang.Exception
        Throws:
        java.lang.Exception

      • eventLoop

        protected void eventLoop​(JChannel ch)

      • process

        protected boolean process​(java.lang.String line)

      • sendTo

        protected void sendTo​(java.lang.String line)

      • printTopo

        protected java.lang.String printTopo​(java.lang.String line,
                                     java.lang.String command,
                                     boolean refresh)

      • help

        protected static void help()