com.hazelcast.client

Class ClientRequest

java.lang.Object

com.hazelcast.client.ClientRequest

All Implemented Interfaces:

SecureRequest, Portable, VersionedPortable

Direct Known Subclasses:

AllPartitionsClientRequest, CallableClientRequest, GetDistributedObjectsRequest, InvocationClientRequest, MultiPartitionClientRequest, MultiTargetClientRequest, PartitionClientRequest, TargetClientRequest

public abstract class ClientRequest
extends Object
implements SecureRequest, VersionedPortable

Field Summary

Fields

Modifier and Type	Field and Description
protected int	callId
protected ClientEngineImpl	clientEngine
protected ClientEndpoint	endpoint
protected Object	service

Constructor Summary

Constructors

Constructor and Description
ClientRequest()

Method Summary

Methods

Modifier and Type	Method and Description
int	getCallId()
int	getClassVersion() Version for internal requests.
ClientEngine	getClientEngine()
ClientEndpoint	getEndpoint()
<S> S	getService()
abstract String	getServiceName()
boolean	isSingleConnection()
void	read(PortableReader reader)
void	readPortable(PortableReader reader) Read portable fields using PortableReader
void	setCallId(int callId)
void	setSingleConnection() mark this request as SingleConnection
void	write(PortableWriter writer)
void	writePortable(PortableWriter writer) Serialize this portable object using PortableWriter

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.client.SecureRequest

getRequiredPermission

Methods inherited from interface com.hazelcast.nio.serialization.Portable

getClassId, getFactoryId

Field Detail

callId

protected int callId

clientEngine

protected transient ClientEngineImpl clientEngine

service

protected transient Object service

endpoint

protected transient ClientEndpoint endpoint

Constructor Detail

ClientRequest

public ClientRequest()

Method Detail

setSingleConnection

public void setSingleConnection()

mark this request as SingleConnection

isSingleConnection

public boolean isSingleConnection()

Returns:

true if this request is SingleConnection false otherwise

getClientEngine

public ClientEngine getClientEngine()

getService

public <S> S getService()

getEndpoint

public ClientEndpoint getEndpoint()

getServiceName

public abstract String getServiceName()

getCallId

public int getCallId()

setCallId

public void setCallId(int callId)

writePortable

public final void writePortable(PortableWriter writer)
                         throws IOException

Description copied from interface: Portable

Serialize this portable object using PortableWriter

Specified by:

writePortable in interface Portable

Parameters:

writer - PortableWriter

Throws:

IOException

write

public void write(PortableWriter writer)
           throws IOException

Throws:

IOException

readPortable

public final void readPortable(PortableReader reader)
                        throws IOException

Description copied from interface: Portable

Read portable fields using PortableReader

Specified by:

readPortable in interface Portable

Parameters:

reader - PortableReader

Throws:

IOException

read

public void read(PortableReader reader)
          throws IOException

Throws:

IOException

getClassVersion

public int getClassVersion()

Version for internal requests. This version can be configured per class by overriding this method.

This should be updated/incremented when serialization of a request changes.

Specified by:

getClassVersion in interface VersionedPortable

Returns:

class version