Class InternalBabelChannel

java.lang.Object
pt.unl.fct.di.novasys.babel2.channels.internal.InternalBabelChannel
All Implemented Interfaces:
BabelChannel
public final class InternalBabelChannel extends Object implements BabelChannel
An in-process (in-JVM) implementation of BabelChannel intended for testing and single-process multi-protocol scenarios.

Messages are delivered synchronously between InternalBabelNodeComponent instances that share the same JVM. No actual network I/O occurs; instead, the channel passes messages directly to the target node's Babel runtime via Babel.deliverInMessage(MessageInEvent).

Connection semantics are simulated: calling connect(BabelNode) sets up a InternalConnection object and triggers a ConnectionUpEvent on both sides. Queued messages are drained immediately once the connection is open. Calling disconnect(BabelNode) triggers a ConnectionDownEvent.

Use builder() to obtain an InternalBabelChannelBuilder.

See Also:

  • 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

    • builder

      public static InternalBabelChannelBuilder builder()
      Creates a new builder for InternalBabelChannel.
      Returns:
      a new internal babel channel builder