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

Class ClientRequest

java.lang.Object

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

All Implemented Interfaces:

ClientListenerRequest

Direct Known Subclasses:

ClientAtomicLongCreateRequest, ClientAtomicLongRequest, ClientBinaryConfigurationGetRequest, ClientBinaryTypeGetRequest, ClientBinaryTypeNameGetRequest, ClientBinaryTypeNamePutRequest, ClientBinaryTypePutRequest, ClientCacheCreateWithConfigurationRequest, ClientCacheCreateWithNameRequest, ClientCacheDestroyRequest, ClientCacheGetNamesRequest, ClientCacheGetOrCreateWithConfigurationRequest, ClientCacheGetOrCreateWithNameRequest, ClientCachePartitionsRequest, ClientCacheQueryNextPageRequest, ClientCacheRequest, ClientCacheStopWarmupRequest, ClientClusterChangeStateRequest, ClientClusterGetStateRequest, ClientClusterGroupGetNodeIdsRequest, ClientClusterGroupGetNodesDetailsRequest, ClientClusterGroupGetNodesEndpointsRequest, ClientClusterWalChangeStateRequest, ClientClusterWalGetStateRequest, ClientDataStreamerAddDataRequest, ClientDataStreamerStartRequest, ClientExecuteTaskRequest, ClientGetIdleTimeoutRequest, ClientIgniteSetGetOrCreateRequest, ClientIgniteSetIteratorGetPageRequest, ClientIgniteSetRequest, ClientRawRequest, ClientResourceCloseRequest, ClientServiceGetDescriptorRequest, ClientServiceGetDescriptorsRequest, ClientServiceInvokeRequest, ClientServiceTopologyRequest, ClientTxEndRequest, ClientTxStartRequest

public class ClientRequest
extends Object
implements ClientListenerRequest

Thin client request.

Field Summary

Fields inherited from interface org.apache.ignite.internal.processors.odbc.ClientListenerRequest

HANDSHAKE

Constructor Summary

Constructors

Constructor	Description
ClientRequest(long reqId)	Constructor.
ClientRequest(BinaryRawReader reader)	Constructor.

Method Summary

Modifier and Type	Method	Description
boolean	isAsync(ClientConnectionContext ctx)
ClientResponse	process(ClientConnectionContext ctx)	Processes the request.
IgniteInternalFuture<ClientResponse>	processAsync(ClientConnectionContext ctx)	Processes the request asynchronously.
long	requestId()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.odbc.ClientListenerRequest

beforeStartupRequest

Constructor Detail

ClientRequest

public ClientRequest(BinaryRawReader reader)

Constructor.

Parameters:

reader - Reader.

ClientRequest

public ClientRequest(long reqId)

Constructor.

Parameters:

reqId - Request id.

Method Detail

requestId

public long requestId()

Specified by:

requestId in interface ClientListenerRequest

Returns:

Request ID.

process

public ClientResponse process(ClientConnectionContext ctx)

Processes the request.

Returns:

Response.

processAsync

public IgniteInternalFuture<ClientResponse> processAsync(ClientConnectionContext ctx)

Processes the request asynchronously.

Returns:

Future for response.

isAsync

public boolean isAsync(ClientConnectionContext ctx)

Parameters:

ctx - Client connection context.

Returns:

True if request should be processed asynchronously.