Class SocketReceiver

    • Constructor Detail

      • SocketReceiver

        public SocketReceiver()
    • Method Detail

      • shouldStart

        protected boolean shouldStart()
        Determines whether this receiver should start.

        Subclasses will implement this method to do any subclass-specific validation. The subclass's ReceiverBase.getRunnableTask() method will be invoked (and the task returned will be submitted to the executor) if and only if this method returns true

        Specified by:
        shouldStart in class ReceiverBase
        Returns:
        flag indicating whether this receiver should start
      • onStop

        protected void onStop()
        Allows a subclass to participate in receiver shutdown.
        Specified by:
        onStop in class ReceiverBase
      • getRunnableTask

        protected java.lang.Runnable getRunnableTask()
        Description copied from class: ReceiverBase
        Provides the runnable task this receiver will execute.
        Specified by:
        getRunnableTask in class ReceiverBase
        Returns:
        runnable task
      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
      • newConnector

        protected SocketConnector newConnector​(java.net.InetAddress address,
                                               int port,
                                               int initialDelay,
                                               int retryDelay)
      • getSocketFactory

        protected javax.net.SocketFactory getSocketFactory()
      • setRemoteHost

        public void setRemoteHost​(java.lang.String remoteHost)
      • setPort

        public void setPort​(int port)
      • setReconnectionDelay

        public void setReconnectionDelay​(int reconnectionDelay)
      • setAcceptConnectionTimeout

        public void setAcceptConnectionTimeout​(int acceptConnectionTimeout)