Package org.apache.catalina.tribes

Interface ChannelReceiver

All Superinterfaces:
Heartbeat
All Known Implementing Classes:
BioReceiver, NioReceiver, ReceiverBase
public interface ChannelReceiver extends Heartbeat
The ChannelReceiver interface is the data receiver component at the bottom layer, the IO layer (for layers see the Channel interface). This class may optionally implement a thread pool for parallel processing of incoming messages.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final int
    MAX_UDP_SIZE
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Channel
    getChannel()
    Return the channel that is related to this ChannelReceiver
    String
    getHost()
    String representation of the IPv4 or IPv6 address that this host is listening to.
    MessageListener
    getMessageListener()
    Returns the message listener that is associated with this receiver
    int
    getPort()
    Returns the listening port
    int
    getSecurePort()
    Returns the secure listening port
    int
    getUdpPort()
    Returns the UDP port
    void
    setChannel(Channel channel)
    Set the channel that is related to this ChannelReceiver
    void
    setMessageListener(MessageListener listener)
    Sets the message listener to receive notification of incoming
    void
    start()
    Start listening for incoming messages on the host/port
    void
    stop()
    Stop listening for messages

    Methods inherited from interface org.apache.catalina.tribes.Heartbeat

    heartbeat

  • Field Details

  • Method Details

    • start

      void start() throws IOException
      Start listening for incoming messages on the host/port
      Throws:
      IOException - Listen failed

    • stop

      void stop()
      Stop listening for messages

    • getHost

      String getHost()
      String representation of the IPv4 or IPv6 address that this host is listening to.
      Returns:
      the host that this receiver is listening to

    • getPort

      int getPort()
      Returns the listening port
      Returns:
      port

    • getSecurePort

      int getSecurePort()
      Returns the secure listening port
      Returns:
      port, -1 if a secure port is not activated

    • getUdpPort

      int getUdpPort()
      Returns the UDP port
      Returns:
      port, -1 if the UDP port is not activated.

    • setMessageListener

      void setMessageListener(MessageListener listener)
      Sets the message listener to receive notification of incoming
      Parameters:
      listener - MessageListener
      See Also:

    • getMessageListener

      MessageListener getMessageListener()
      Returns the message listener that is associated with this receiver
      Returns:
      MessageListener
      See Also:

    • getChannel

      Channel getChannel()
      Return the channel that is related to this ChannelReceiver
      Returns:
      Channel

    • setChannel

      void setChannel(Channel channel)
      Set the channel that is related to this ChannelReceiver
      Parameters:
      channel - The channel