Package com.lucimber.dbus.netty

Class NettyConnectionHandle

java.lang.Object

com.lucimber.dbus.netty.NettyConnectionHandle

All Implemented Interfaces:

ConnectionHandle

public final class NettyConnectionHandle
extends Object
implements ConnectionHandle

Netty-based implementation of ConnectionHandle.

This class wraps a Netty Channel and provides the transport-agnostic ConnectionHandle interface for the D-Bus connection layer.

Constructor Summary

Constructors

Constructor	Description
NettyConnectionHandle(io.netty.channel.Channel channel, io.netty.channel.EventLoopGroup eventLoopGroup, ConnectionConfig config, RealityCheckpoint realityCheckpoint)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	close()	Closes this connection handle and releases associated resources.
String	getAssignedBusName()	Gets the assigned D-Bus name for this connection, if available.
DBusUInt32	getNextSerial()	Gets the next available serial number for message sequencing.
boolean	isActive()	Checks if the connection is currently active and ready for communication.
CompletionStage<Void>	send(OutboundMessage message)	Sends a message over this connection.
CompletionStage<InboundMessage>	sendRequest(OutboundMessage message)	Sends a request message and waits for a response.

Methods inherited from class java.lang.Object

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

Constructor Details

NettyConnectionHandle

public NettyConnectionHandle(io.netty.channel.Channel channel,
 io.netty.channel.EventLoopGroup eventLoopGroup,
 ConnectionConfig config,
 RealityCheckpoint realityCheckpoint)

Method Details

isActive

public boolean isActive()

Description copied from interface: ConnectionHandle

Checks if the connection is currently active and ready for communication.

Specified by:

isActive in interface ConnectionHandle

Returns:

true if the connection is active

send

public CompletionStage<Void> send(OutboundMessage message)

Description copied from interface: ConnectionHandle

Sends a message over this connection.

Specified by:

send in interface ConnectionHandle

Parameters:

message - the outbound message to send

Returns:

CompletionStage that completes when the message is sent

sendRequest

public CompletionStage<InboundMessage> sendRequest(OutboundMessage message)

Description copied from interface: ConnectionHandle

Sends a request message and waits for a response.

Specified by:

sendRequest in interface ConnectionHandle

Parameters:

message - the outbound request message

Returns:

CompletionStage that completes with the response message

getNextSerial

public DBusUInt32 getNextSerial()

Description copied from interface: ConnectionHandle

Gets the next available serial number for message sequencing.

Specified by:

getNextSerial in interface ConnectionHandle

Returns:

the next serial number

close

public CompletionStage<Void> close()

Description copied from interface: ConnectionHandle

Closes this connection handle and releases associated resources.

Specified by:

close in interface ConnectionHandle

Returns:

CompletionStage that completes when the connection is closed

getAssignedBusName

public String getAssignedBusName()

Description copied from interface: ConnectionHandle

Gets the assigned D-Bus name for this connection, if available.

Specified by:

getAssignedBusName in interface ConnectionHandle

Returns:

the assigned bus name, or null if not yet assigned