Class TcpSender

  • All Implemented Interfaces:
    Sender

    public class TcpSender
    extends Object
    implements Sender
    • Field Detail

      • proxies

        protected Proxy[] proxies
        Proxies.
      • connections

        protected Socket[] connections
        Active connections.
    • Constructor Detail

      • TcpSender

        public TcpSender()
    • Method Detail

      • init

        public void init​(HeartbeatListener config)
                  throws Exception
        Description copied from interface: Sender
        Set the configuration parameters
        Specified by:
        init in interface Sender
        Parameters:
        config - The heartbeat listener configuration
        Throws:
        Exception - An error occurred
      • send

        public int send​(String mess)
                 throws Exception
        Description copied from interface: Sender
        Send the message to the proxies
        Specified by:
        send in interface Sender
        Parameters:
        mess - The message that will be sent
        Returns:
        0 if no error occurred, -1 otherwise
        Throws:
        Exception - An error occurred
      • close

        protected void close​(int i)
        Close connection.
        Parameters:
        i - The index of the connection that will be closed