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

Class ClientRequestHandler

java.lang.Object

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

All Implemented Interfaces:

ClientListenerRequestHandler

public class ClientRequestHandler
extends Object
implements ClientListenerRequestHandler

Thin client request handler.

Field Summary

Fields

Modifier and Type	Field	Description
static long	DFLT_ASYNC_REQUEST_WAIT_TIMEOUT_MILLIS	Timeout to wait for async requests completion, to handle them as regular sync requests.

Method Summary

Modifier and Type	Method	Description
ClientListenerResponse	handle(ClientListenerRequest req)	Handle request.
ClientListenerResponse	handleException(Throwable e, ClientListenerRequest req)	Handle exception.
boolean	isCancellationCommand(int cmdId)	Detect whether given command is a cancellation command.
boolean	isCancellationSupported()	Checks whether query cancellation is supported within given version of protocol.
ClientListenerProtocolVersion	protocolVersion()
void	registerRequest(long reqId, int cmdType)	Registers request for futher cancellation if any.
void	unregisterRequest(long reqId)	Try to unregister request.
void	writeHandshake(BinaryWriterExImpl writer)	Write successful handshake response.

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_ASYNC_REQUEST_WAIT_TIMEOUT_MILLIS

public static final long DFLT_ASYNC_REQUEST_WAIT_TIMEOUT_MILLIS

Timeout to wait for async requests completion, to handle them as regular sync requests.

See Also:

Constant Field Values

Method Detail

handle

public ClientListenerResponse handle(ClientListenerRequest req)

Handle request.

Specified by:

handle in interface ClientListenerRequestHandler

Parameters:

req - Request.

Returns:

Response.

handleException

public ClientListenerResponse handleException(Throwable e,
                                              ClientListenerRequest req)

Handle exception.

Specified by:

handleException in interface ClientListenerRequestHandler

Parameters:

e - Exception.

req - Request.

Returns:

Error response.

writeHandshake

public void writeHandshake(BinaryWriterExImpl writer)

Write successful handshake response.

Specified by:

writeHandshake in interface ClientListenerRequestHandler

Parameters:

writer - Binary writer.

isCancellationCommand

public boolean isCancellationCommand(int cmdId)

Detect whether given command is a cancellation command.

Specified by:

isCancellationCommand in interface ClientListenerRequestHandler

Parameters:

cmdId - Command Id

Returns:

true if given command is cancellation one, false otherwise;

isCancellationSupported

public boolean isCancellationSupported()

Checks whether query cancellation is supported within given version of protocol.

Specified by:

isCancellationSupported in interface ClientListenerRequestHandler

Returns:

true if supported, false otherwise.

registerRequest

public void registerRequest(long reqId,
                            int cmdType)

Registers request for futher cancellation if any.

Specified by:

registerRequest in interface ClientListenerRequestHandler

Parameters:

reqId - Request Id.

cmdType - Command Type.

unregisterRequest

public void unregisterRequest(long reqId)

Try to unregister request.

Specified by:

unregisterRequest in interface ClientListenerRequestHandler

Parameters:

reqId - Request Id.

protocolVersion

public ClientListenerProtocolVersion protocolVersion()

Specified by:

protocolVersion in interface ClientListenerRequestHandler

Returns:

Protocol version.