Class AbstractIPBabelChannelBuilder<T extends BabelChannelBuilder>

java.lang.Object

pt.unl.fct.di.novasys.babel2.channels.AbstractBabelChannelBuilder<T>

pt.unl.fct.di.novasys.babel2.channels.AbstractIPBabelChannelBuilder<T>

Type Parameters:

T - the concrete builder subtype for fluent method chaining

All Implemented Interfaces:

BabelChannelBuilder

Direct Known Subclasses:

LegacySimpleServerBabelChannelBuilder, QUICBabelChannelBuilder, TCPBabelChannelBuilder, TLSBabelChannelBuilder, UDPBabelChannelBuilder

public abstract class AbstractIPBabelChannelBuilder<T extends BabelChannelBuilder>
extends AbstractBabelChannelBuilder<T>

Base builder for channel implementations operating over IP networks.

Provides common configuration options such as binding socket addresses, Netty event loop groups, and connection-up notification delays.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_CONNECTION_UP_DELAY	Default delay in milliseconds before dispatching connection-up notifications.
static final TimeUnit	DEFAULT_CONNECTION_UP_DELAY_UNIT	Default time unit for DEFAULT_CONNECTION_UP_DELAY.

Fields inherited from class AbstractBabelChannelBuilder

DEFAULT_NUMBER_OF_CONNECTIONS, DEFAULT_NUMBER_OF_MESSAGES

Modifier and Type	Field	Description
static final int	DEFAULT_NUMBER_OF_CONNECTIONS	Default number of connections to expect when initializing the channel.
static final int	DEFAULT_NUMBER_OF_MESSAGES	Default number of message types expected by this channel.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractIPBabelChannelBuilder()	Initializes a new IP channel builder with default settings.

Method Summary

Modifier and Type	Method	Description
protected final InetSocketAddress	getBindingAddress()	Returns the currently configured binding address.
protected final long	getConnectionUpDelay()	Returns the configured connection up delay value.
protected final TimeUnit	getConnectionUpDelayUnit()	Returns the time unit of the connection up delay.
protected final io.netty.channel.EventLoopGroup	getEventLoopGroup()	Returns the configured event loop group, initializing a default one via BabelIpUtils.createLoopGroup() if none has been set.
final T	setBindingAddress(InetSocketAddress bindingAddress)	Sets the local IP socket address to which the channel should bind.
final T	setConnectionUpDelay(long delayMillis)	Sets the delay in milliseconds before notifying the runtime that a connection is fully up.
final T	setConnectionUpDelay(long delay, TimeUnit unit)	Sets the delay and unit before notifying the runtime that a connection is fully up.
final T	setEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)	Configures the Netty EventLoopGroup used for network I/O.

Methods inherited from class AbstractBabelChannelBuilder

getChannel, getNumberOfConnections, getNumberOfMessages, setChannel, setNumberOfConnections, setNumberOfMessages, validateStateOrThrow

Modifier and Type	Method	Description
protected final @Nullable BabelChannel	getChannel()	Returns the channel instance created by this builder, or null if not yet built.
protected final int	getNumberOfConnections()	Gets the expected number of connections set in this builder.
protected final int	getNumberOfMessages()	Gets the expected number of messages set in this builder.
protected final void	setChannel(BabelChannel channel)	Sets the constructed channel instance created by this builder.
final T	setNumberOfConnections(int numberOfConnections)	Sets the default number of connections expected.
final T	setNumberOfMessages(int numberOfMessages)	Sets the expected number of distinct message types handled by this channel.
protected final void	validateStateOrThrow()	Validates that this builder has not yet built its channel instance.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface BabelChannelBuilder

build

Modifier and Type	Method	Description
BabelChannel	build(Babel runtime, NodeStore store, BabelNode identity, BabelProtocol protocol)	Creates a new BabelChannel instance, registering it with the given runtime and limiting its interest to the provided message types.

Field Details

DEFAULT_CONNECTION_UP_DELAY

public static final long DEFAULT_CONNECTION_UP_DELAY

Default delay in milliseconds before dispatching connection-up notifications.

See Also:

• Constant Field Values

DEFAULT_CONNECTION_UP_DELAY_UNIT

public static final TimeUnit DEFAULT_CONNECTION_UP_DELAY_UNIT

Default time unit for DEFAULT_CONNECTION_UP_DELAY.

Constructor Details

AbstractIPBabelChannelBuilder

protected AbstractIPBabelChannelBuilder()

Initializes a new IP channel builder with default settings.

Method Details

setBindingAddress

public final T setBindingAddress(InetSocketAddress bindingAddress)

Sets the local IP socket address to which the channel should bind.

Parameters:

bindingAddress - the socket address to bind to

Returns:

this builder instance

getBindingAddress

protected final InetSocketAddress getBindingAddress()

Returns the currently configured binding address.

Returns:

the local binding address

setEventLoopGroup

public final T setEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)

Configures the Netty EventLoopGroup used for network I/O.

Parameters:

eventLoopGroup - the custom event loop group, or null to allocate a default group

Returns:

this builder instance

getEventLoopGroup

protected final io.netty.channel.EventLoopGroup getEventLoopGroup()

Returns the configured event loop group, initializing a default one via BabelIpUtils.createLoopGroup() if none has been set.

Returns:

the active event loop group

setConnectionUpDelay

public final T setConnectionUpDelay(long delay,
 TimeUnit unit)

Sets the delay and unit before notifying the runtime that a connection is fully up.

Parameters:

delay - the delay duration

unit - the time unit of the delay

Returns:

this builder instance

setConnectionUpDelay

public final T setConnectionUpDelay(long delayMillis)

Sets the delay in milliseconds before notifying the runtime that a connection is fully up.

Parameters:

delayMillis - the delay duration in milliseconds

Returns:

this builder instance

getConnectionUpDelay

protected final long getConnectionUpDelay()

Returns the configured connection up delay value.

Returns:

the connection up delay

getConnectionUpDelayUnit

protected final TimeUnit getConnectionUpDelayUnit()

Returns the time unit of the connection up delay.

Returns:

the connection up delay time unit