Class ReactorNettyTcpConnection<P>

java.lang.Object

org.springframework.messaging.tcp.reactor.ReactorNettyTcpConnection<P>

Type Parameters:

P - the type of payload for outbound messages

All Implemented Interfaces:

Closeable, AutoCloseable, TcpConnection<P>

public class ReactorNettyTcpConnection<P>
extends Object
implements TcpConnection<P>

Reactor Netty based implementation of TcpConnection.

Since:

5.0

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor	Description
ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound, reactor.netty.NettyOutbound outbound, ReactorNettyCodec<P> codec, reactor.core.publisher.Sinks.Empty<Void> completionSink)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the connection.
void	onReadInactivity(Runnable runnable, long inactivityDuration)	Register a task to invoke after a period of read inactivity.
void	onWriteInactivity(Runnable runnable, long inactivityDuration)	Register a task to invoke after a period of write inactivity.
CompletableFuture<Void>	sendAsync(Message<P> message)	Send the given message.
String	toString()

Methods inherited from class Object

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

Constructor Details

ReactorNettyTcpConnection

public ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound,
 reactor.netty.NettyOutbound outbound,
 ReactorNettyCodec<P> codec,
 reactor.core.publisher.Sinks.Empty<Void> completionSink)

Method Details

sendAsync

public CompletableFuture<Void> sendAsync(Message<P> message)

Description copied from interface: TcpConnection

Send the given message.

Specified by:

sendAsync in interface TcpConnection<P>

Parameters:

message - the message

Returns:

a CompletableFuture that can be used to determine when and if the message was successfully sent

onReadInactivity

public void onReadInactivity(Runnable runnable,
 long inactivityDuration)

Description copied from interface: TcpConnection

Register a task to invoke after a period of read inactivity.

Specified by:

onReadInactivity in interface TcpConnection<P>

Parameters:

runnable - the task to invoke

inactivityDuration - the amount of inactive time in milliseconds

onWriteInactivity

public void onWriteInactivity(Runnable runnable,
 long inactivityDuration)

Description copied from interface: TcpConnection

Register a task to invoke after a period of write inactivity.

Specified by:

onWriteInactivity in interface TcpConnection<P>

Parameters:

runnable - the task to invoke

inactivityDuration - the amount of inactive time in milliseconds

close

public void close()

Description copied from interface: TcpConnection

Close the connection.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface TcpConnection<P>

toString

public String toString()

Overrides:

toString in class Object