org.apache.ignite.internal.processors.platform.client

Class ClientConnectionContext

java.lang.Object

org.apache.ignite.internal.processors.platform.client.ClientConnectionContext

All Implemented Interfaces:

ClientListenerConnectionContext

public class ClientConnectionContext
extends Object
implements ClientListenerConnectionContext

Thin Client connection context.

Constructor Summary

Constructors

Constructor and Description
ClientConnectionContext(GridKernalContext ctx, int maxCursors) Ctor.

Method Summary

Modifier and Type	Method and Description
ClientListenerProtocolVersion	currentVersion()
void	decrementCursors() Increments the cursor count.
ClientListenerRequestHandler	handler() Handler getter.
void	incrementCursors() Increments the cursor count.
void	initializeFromHandshake(ClientListenerProtocolVersion ver, BinaryReaderExImpl reader) Initialize from handshake message.
boolean	isVersionSupported(ClientListenerProtocolVersion ver)
GridKernalContext	kernalContext() Gets the kernal context.
void	onDisconnected() Called whenever client is disconnected due to correct connection close or due to IOException during network operations.
ClientListenerMessageParser	parser() Parser getter
ClientResourceRegistry	resources() Gets the handle registry.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientConnectionContext

public ClientConnectionContext(GridKernalContext ctx,
                               int maxCursors)

Ctor.

Parameters:

ctx - Kernal context.

maxCursors - Max active cursors.

Method Detail

resources

public ClientResourceRegistry resources()

Gets the handle registry.

Returns:

Handle registry.

kernalContext

public GridKernalContext kernalContext()

Gets the kernal context.

Returns:

Kernal context.

isVersionSupported

public boolean isVersionSupported(ClientListenerProtocolVersion ver)

Specified by:

isVersionSupported in interface ClientListenerConnectionContext

Parameters:

ver - Version to check.

Returns:

true if version is supported.

currentVersion

public ClientListenerProtocolVersion currentVersion()

Specified by:

currentVersion in interface ClientListenerConnectionContext

Returns:

Current context version.

initializeFromHandshake

public void initializeFromHandshake(ClientListenerProtocolVersion ver,
                                    BinaryReaderExImpl reader)

Initialize from handshake message.

Specified by:

initializeFromHandshake in interface ClientListenerConnectionContext

Parameters:

ver - Protocol version.

reader - Reader set to the configuration part of the handshake message.

handler

public ClientListenerRequestHandler handler()

Handler getter.

Specified by:

handler in interface ClientListenerConnectionContext

Returns:

Request handler for the connection.

parser

public ClientListenerMessageParser parser()

Parser getter

Specified by:

parser in interface ClientListenerConnectionContext

Returns:

Message parser for the connection.

onDisconnected

public void onDisconnected()

Called whenever client is disconnected due to correct connection close or due to IOException during network operations.

Specified by:

onDisconnected in interface ClientListenerConnectionContext

incrementCursors

public void incrementCursors()

Increments the cursor count.

decrementCursors

public void decrementCursors()

Increments the cursor count.