Package org.apache.ignite.internal.processors.odbc

Class ClientListenerNioListener

java.lang.Object

org.apache.ignite.internal.util.nio.GridNioServerListenerAdapter<ClientMessage>

org.apache.ignite.internal.processors.odbc.ClientListenerNioListener

All Implemented Interfaces:

EventListener, GridNioServerListener<ClientMessage>

public class ClientListenerNioListener
extends GridNioServerListenerAdapter<ClientMessage>

Client message listener.

Field Summary

Fields

Modifier and Type	Field	Description
static byte[]	CLI_TYPES	Client types.
static int	CONN_CTX_HANDSHAKE_TIMEOUT_TASK	Connection handshake timeout task.
static int	CONN_CTX_META_KEY	Connection-related metadata key.
static byte	JDBC_CLIENT	JDBC driver handshake code.
static String	MANAGEMENT_CLIENT_ATTR	True if a management client.
static long	MANAGEMENT_CONNECTION_SHIFTED_ID	Connection shifted ID for management clients.
static byte	ODBC_CLIENT	ODBC driver handshake code.
static byte	THIN_CLIENT	Thin client handshake code.

Constructor Summary

Constructors

Constructor	Description
ClientListenerNioListener(GridKernalContext ctx, GridSpinBusyLock busyLock, ClientConnectorConfiguration cliConnCfg, ClientListenerMetrics metrics)	Constructor.

Method Summary

Modifier and Type	Method	Description
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, ClientMessage msg)	This method is called whenever a GridNioParser returns non-null value.
void	onSessionIdleTimeout(GridNioSession ses)	Called when session did not receive any activity within timeout interval.

Methods inherited from class org.apache.ignite.internal.util.nio.GridNioServerListenerAdapter

onMessageSent, onSessionWriteTimeout

Methods inherited from class java.lang.Object

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

Field Detail

ODBC_CLIENT

public static final byte ODBC_CLIENT

ODBC driver handshake code.

See Also:

Constant Field Values

JDBC_CLIENT

public static final byte JDBC_CLIENT

JDBC driver handshake code.

See Also:

Constant Field Values

THIN_CLIENT

public static final byte THIN_CLIENT

Thin client handshake code.

See Also:

Constant Field Values

CLI_TYPES

public static final byte[] CLI_TYPES

Client types.

CONN_CTX_HANDSHAKE_TIMEOUT_TASK

public static final int CONN_CTX_HANDSHAKE_TIMEOUT_TASK

Connection handshake timeout task.

CONN_CTX_META_KEY

public static final int CONN_CTX_META_KEY

Connection-related metadata key.

MANAGEMENT_CLIENT_ATTR

public static final String MANAGEMENT_CLIENT_ATTR

True if a management client. Internal operations will be available.

See Also:

Constant Field Values

MANAGEMENT_CONNECTION_SHIFTED_ID

public static final long MANAGEMENT_CONNECTION_SHIFTED_ID

Connection shifted ID for management clients.

See Also:

Constant Field Values

Constructor Detail

ClientListenerNioListener

public ClientListenerNioListener(GridKernalContext ctx,
                                 GridSpinBusyLock busyLock,
                                 ClientConnectorConfiguration cliConnCfg,
                                 ClientListenerMetrics metrics)

Constructor.

Parameters:

ctx - Context.

busyLock - Shutdown busy lock.

cliConnCfg - Client connector configuration.

metrics - Client listener metrics.

Method Detail

onConnected

public void onConnected(GridNioSession ses)

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

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.

Parameters:

ses - Closed session.

e - Exception occurred, if any.

onMessage

public void onMessage(GridNioSession ses,
                      ClientMessage msg)

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

Parameters:

ses - Session on which message was received.

msg - Parsed message.

onSessionIdleTimeout

public void onSessionIdleTimeout(GridNioSession ses)

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

Specified by:

onSessionIdleTimeout in interface GridNioServerListener<ClientMessage>

Overrides:

onSessionIdleTimeout in class GridNioServerListenerAdapter<ClientMessage>

Parameters:

ses - Session that is idle.

onFailure

public void onFailure(FailureType failureType,
                      Throwable failure)

Called when critical failure occurs in server implementation.

Specified by:

onFailure in interface GridNioServerListener<ClientMessage>

Overrides:

onFailure in class GridNioServerListenerAdapter<ClientMessage>