Class ComposedBabelChannel

java.lang.Object
pt.unl.fct.di.novasys.babel2.channels.ComposedBabelChannel
All Implemented Interfaces:
BabelChannel
public class ComposedBabelChannel extends Object implements BabelChannel
A BabelChannel that composes many underlying channels.

This design allows a protocol to use different transport strategies for different communication patterns without any changes to the protocol code.

See Also:

  • Constructor Details

    • ComposedBabelChannel

      public ComposedBabelChannel(Babel runtime, BabelChannel... channels)
      Creates a new ComposedBabelChannel from the given channels.
      Parameters:
      runtime - the Babel runtime
      channels - the channels to compose

  • 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

    • 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

    • 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

    • 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

    • getConcreteChannel

      public <T extends BabelChannel> List<T> getConcreteChannel(Class<T> type)
      Gets all concrete channels of the specified type from the composed channels.
      Type Parameters:
      T - the type of channel
      Parameters:
      type - the class of the channel type to get
      Returns:
      an immutable list of channels of the given type