Class LegacySimpleServerBabelChannel

java.lang.Object
pt.unl.fct.di.novasys.babel2.channels.legacy.simpleServer.LegacySimpleServerBabelChannel
All Implemented Interfaces:
BabelChannel, IPBabelChannel
public class LegacySimpleServerBabelChannel extends Object implements IPBabelChannel
Legacy server-side channel implementation supporting backward compatibility with older simple-client protocols.

Handles incoming connections, simple handshake validation, periodic heartbeats, and frame framing.

  • Method Details

    • connect

      public void connect(BabelNode peer)
      Description copied from interface: BabelChannel
      Connect to another Babel runtime. The pecularities of how a channel "connects" to another Babel runtime is up to its implementation. Whether the connection is successful or not, this method should trigger the ConnectionUpEvent or ConnectionFailedEvent. May throw UnsupportedOperationException
      Specified by:
      connect in interface BabelChannel
      Parameters:
      peer - the peer to connect to

    • send

      public void send(BabelNode peer, BabelMessage message)
      Description copied from interface: BabelChannel
      Sends a message through this channel to the given peer using a persistent connection. If the connection is not currently open, the message may be queued depending on the implementation.
      Specified by:
      send in interface BabelChannel
      Parameters:
      peer - the peer to send the message to
      message - the message to be sent

    • sendEphemeral

      public void sendEphemeral(BabelNode peer, BabelMessage message)
      Description copied from interface: BabelChannel
      Sends a message to peer without establishing a persistent connection. The channel implementation may use a transient transport internally, but none of the connection lifecycle events (connectionUp / connectionDown) are triggered.
      Specified by:
      sendEphemeral in interface BabelChannel
      Parameters:
      peer - the target node
      message - the message to deliver

    • disconnect

      public void disconnect(BabelNode peer)
      Description copied from interface: BabelChannel
      Closes the connection to peer. A ConnectionDownEvent will be delivered to interested protocols after the connection has been torn down.
      Specified by:
      disconnect in interface BabelChannel
      Parameters:
      peer - the node to disconnect from

    • isConnected

      public boolean isConnected(BabelNode peer)
      Description copied from interface: BabelChannel
      Returns true if a connection to peer is currently open on this channel.
      Specified by:
      isConnected in interface BabelChannel
      Parameters:
      peer - the node whose connection status is queried
      Returns:
      true if connected, false otherwise

    • shutdown

      public void shutdown()
      Description copied from interface: BabelChannel
      Releases all resources held by this channel, closing any open connections.
      Specified by:
      shutdown in interface BabelChannel

    • getBindingAddress

      public InetSocketAddress getBindingAddress()
      Description copied from interface: IPBabelChannel
      Returns the local IP socket address to which this channel is bound.
      Specified by:
      getBindingAddress in interface IPBabelChannel
      Returns:
      the local binding InetSocketAddress

    • builder

      public static LegacySimpleServerBabelChannelBuilder builder()
      Returns a new LegacySimpleServerBabelChannelBuilder instance.
      Returns:
      a new legacy server channel builder