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 and Description
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 byte	ODBC_CLIENT ODBC driver handshake code.
static byte	THIN_CLIENT Thin client handshake code.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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

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.

Constructor Detail

ClientListenerNioListener

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

Constructor.

Parameters:

ctx - Context.

busyLock - Shutdown busy lock.

cliConnCfg - Client connector configuration.

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>