public abstract class ClientProxy extends Object implements DistributedObject
Allows the client to proxy operations through member nodes.
| Modifier | Constructor and Description |
|---|---|
protected |
ClientProxy(String serviceName,
String name) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
deregisterListener(String registrationId) |
void |
destroy()
Destroys this object cluster-wide.
|
boolean |
equals(Object o) |
protected HazelcastClientInstanceImpl |
getClient() |
protected int |
getConnectedServerVersion() |
ClientContext |
getContext() |
protected String |
getDistributedObjectName() |
Object |
getId()
Deprecated.
|
String |
getName()
Returns the unique name for this DistributedObject.
|
String |
getPartitionKey()
Returns the key of the partition that this DistributedObject is assigned to.
|
protected SerializationService |
getSerializationService() |
String |
getServiceName()
Returns the service name for this object.
|
int |
hashCode() |
protected <T> T |
invoke(ClientMessage clientMessage) |
protected <T> T |
invoke(ClientMessage clientMessage,
Object key) |
protected <T> T |
invokeOnAddress(ClientMessage clientMessage,
Address address) |
protected <T> T |
invokeOnPartition(ClientMessage clientMessage,
int partitionId) |
protected <T> T |
invokeOnPartitionInterruptibly(ClientMessage clientMessage,
int partitionId) |
protected void |
onDestroy()
Called before proxy is destroyed.
|
protected void |
onInitialize()
Called when proxy is created.
|
protected void |
onShutdown()
Called before client shutdown.
|
protected void |
postDestroy()
Called after proxy is destroyed.
|
protected boolean |
preDestroy()
Called before proxy is destroyed and determines whether destroy should be done.
|
protected String |
registerListener(ListenerMessageCodec codec,
EventHandler handler) |
protected void |
setContext(ClientContext context) |
protected Data |
toData(Object o) |
protected <T> T |
toObject(Object data) |
protected final String name
protected final String registerListener(ListenerMessageCodec codec, EventHandler handler)
protected final boolean deregisterListener(String registrationId)
public final ClientContext getContext()
protected final void setContext(ClientContext context)
protected final HazelcastClientInstanceImpl getClient()
protected final int getConnectedServerVersion()
@Deprecated public final Object getId()
public final String getName()
DistributedObjectDistributedObjectUtil.getName(DistributedObject)
because this might be also a PrefixedDistributedObject.getName in interface DistributedObjectpublic String getPartitionKey()
DistributedObjectIAtomicLong. For a partitioned data structure like an IMap,
the returned value will not be null, but otherwise undefined.getPartitionKey in interface DistributedObjectpublic final String getServiceName()
DistributedObjectgetServiceName in interface DistributedObjectprotected String getDistributedObjectName()
public final void destroy()
DistributedObjectdestroy in interface DistributedObjectprotected void onInitialize()
protected void onDestroy()
protected boolean preDestroy()
true if destroy should be done, otherwise falseprotected void postDestroy()
protected void onShutdown()
protected <T> T invoke(ClientMessage clientMessage, Object key)
protected <T> T invokeOnPartition(ClientMessage clientMessage, int partitionId)
protected <T> T invokeOnAddress(ClientMessage clientMessage, Address address)
protected <T> T invokeOnPartitionInterruptibly(ClientMessage clientMessage, int partitionId) throws InterruptedException
InterruptedExceptionprotected <T> T invoke(ClientMessage clientMessage)
protected SerializationService getSerializationService()
protected <T> T toObject(Object data)
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.