Package org.springframework.messaging.tcp.reactor

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 java.lang.Object

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

Methods inherited from interface org.springframework.messaging.tcp.TcpConnection

send

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