org.springframework.messaging.tcp.reactor

Class Reactor2TcpConnection<P>

java.lang.Object

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

Type Parameters:

P - the payload type of messages read or written to the TCP stream.

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, TcpConnection<P>

public class Reactor2TcpConnection<P>
extends java.lang.Object
implements TcpConnection<P>

An implementation of TcpConnection based on the TCP client support of the Reactor project.

Since:

4.2

Author:

Rossen Stoyanchev

Field Summary

Fields

Modifier and Type	Field and Description
private <any>	channelStream
private <any>	closePromise

Constructor Summary

Constructors

Constructor and Description
Reactor2TcpConnection(<any> channelStream, <any> closePromise)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

channelStream

private final <any> channelStream

closePromise

private final <any> closePromise

Constructor Detail

Reactor2TcpConnection

public Reactor2TcpConnection(<any> channelStream,
                             <any> closePromise)

Method Detail

send

public ListenableFuture<java.lang.Void> send(Message<P> message)

Description copied from interface: TcpConnection

Send the given message.

Specified by:

send in interface TcpConnection<P>

Parameters:

message - the message

Returns:

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

onReadInactivity

public void onReadInactivity(java.lang.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(java.lang.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 java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface TcpConnection<P>