org.apache.ignite.internal.client.router.impl

Class GridTcpRouterNioListenerAdapter

java.lang.Object

org.apache.ignite.internal.client.router.impl.GridTcpRouterNioListenerAdapter

All Implemented Interfaces:

EventListener, GridNioServerListener<GridClientMessage>

public abstract class GridTcpRouterNioListenerAdapter
extends Object
implements GridNioServerListener<GridClientMessage>

Nio listener for the router. Extracts necessary meta information from messages and delegates their delivery to underlying client.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Byte,GridClientMarshaller>	marshMap Marshallers map.

Constructor Summary

Constructors

Constructor and Description
GridTcpRouterNioListenerAdapter(IgniteLogger log, GridRouterClientImpl client)

Method Summary

Modifier and Type	Method and Description
protected abstract void	init()
void	onConnected(GridNioSession ses) This method is called whenever a new client is connected and session is created.
void	onDisconnected(GridNioSession ses, @Nullable Exception e) This method is called whenever client is disconnected due to correct connection close or due to IOException during network operations.
void	onFailure(FailureType failureType, Throwable failure) Called when critical failure occurs in server implementation.
void	onMessage(GridNioSession ses, GridClientMessage msg) This method is called whenever a GridNioParser returns non-null value.
void	onMessageSent(GridNioSession ses, GridClientMessage msg) Handle message sent.
void	onSessionIdleTimeout(GridNioSession ses) Called when session did not receive any activity within timeout interval.
void	onSessionWriteTimeout(GridNioSession ses) Called when session has non-empty write queue and server did not send any data within timeout interval.

Methods inherited from class java.lang.Object

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

Field Detail

marshMap

protected final Map<Byte,GridClientMarshaller> marshMap

Marshallers map.

Constructor Detail

GridTcpRouterNioListenerAdapter

public GridTcpRouterNioListenerAdapter(IgniteLogger log,
                                       GridRouterClientImpl client)

Parameters:

log - Logger.

client - Client for grid access.

Method Detail

init

protected abstract void init()

onConnected

public void onConnected(GridNioSession ses)

This method is called whenever a new client is connected and session is created.

Specified by:

onConnected in interface GridNioServerListener<GridClientMessage>

Parameters:

ses - Newly created session for remote client.

onDisconnected

public void onDisconnected(GridNioSession ses,
                           @Nullable
                           @Nullable Exception e)

This method is called whenever client is disconnected due to correct connection close or due to IOException during network operations.

Specified by:

onDisconnected in interface GridNioServerListener<GridClientMessage>

Parameters:

ses - Closed session.

e - Exception occurred, if any.

onMessageSent

public void onMessageSent(GridNioSession ses,
                          GridClientMessage msg)

Handle message sent.

Specified by:

onMessageSent in interface GridNioServerListener<GridClientMessage>

Parameters:

ses - Session.

msg - Message.

onMessage

public void onMessage(GridNioSession ses,
                      GridClientMessage msg)

This method is called whenever a GridNioParser returns non-null value.

Specified by:

onMessage in interface GridNioServerListener<GridClientMessage>

Parameters:

ses - Session on which message was received.

msg - Parsed message.

onFailure

public void onFailure(FailureType failureType,
                      Throwable failure)

Called when critical failure occurs in server implementation.

Specified by:

onFailure in interface GridNioServerListener<GridClientMessage>

onSessionWriteTimeout

public void onSessionWriteTimeout(GridNioSession ses)

Called when session has non-empty write queue and server did not send any data within timeout interval.

Specified by:

onSessionWriteTimeout in interface GridNioServerListener<GridClientMessage>

Parameters:

ses - Session that has timed out writes.

onSessionIdleTimeout

public void onSessionIdleTimeout(GridNioSession ses)

Called when session did not receive any activity within timeout interval.

Specified by:

onSessionIdleTimeout in interface GridNioServerListener<GridClientMessage>

Parameters:

ses - Session that is idle.