Class RelayDemoRpc

  • All Implemented Interfaces:
    Receiver

    public class RelayDemoRpc
    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
    • Constructor Detail

      • RelayDemoRpc

        public RelayDemoRpc()
    • Method Detail

      • main

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

        public void start​(java.lang.String props,
                          java.lang.String name)
                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • parseSiteMasters

        protected static java.util.Collection<java.lang.String> parseSiteMasters​(java.lang.String line)
      • handleMessage

        public static java.lang.String handleMessage​(java.lang.String msg,
                                                     java.lang.String sender)
      • 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