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.

Method Summary

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

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.