S
- public abstract class AbstractDistributedObject<S extends RemoteService> extends Object implements DistributedObject
Modifier and Type | Field and Description |
---|---|
protected static PartitioningStrategy |
PARTITIONING_STRATEGY |
Modifier | Constructor and Description |
---|---|
protected |
AbstractDistributedObject(NodeEngine nodeEngine,
S service) |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Destroys this object cluster-wide.
|
boolean |
equals(Object o) |
protected String |
getDistributedObjectName() |
protected Data |
getNameAsPartitionAwareData() |
NodeEngine |
getNodeEngine()
Gets the node engine.
|
OperationService |
getOperationService()
Gets the OperationService.
|
protected int |
getPartitionId(Data key) |
String |
getPartitionKey()
Returns the key of the partition that this DistributedObject is assigned to.
|
S |
getService()
Gets the Service of this AbstractDistributedObject.
|
abstract String |
getServiceName()
Returns the service name for this object.
|
int |
hashCode() |
void |
invalidate() |
protected <E> InternalCompletableFuture<E> |
invokeOnPartition(Operation operation) |
protected void |
postDestroy() |
protected boolean |
preDestroy() |
protected void |
throwNotActiveException() |
protected Data |
toData(Object object) |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getName
protected static final PartitioningStrategy PARTITIONING_STRATEGY
protected AbstractDistributedObject(NodeEngine nodeEngine, S service)
protected String getDistributedObjectName()
protected Data getNameAsPartitionAwareData()
public String getPartitionKey()
DistributedObject
IAtomicLong
. For a partitioned data structure like an IMap
,
the returned value will not be null, but otherwise undefined.getPartitionKey
in interface DistributedObject
public final void destroy()
DistributedObject
destroy
in interface DistributedObject
protected final <E> InternalCompletableFuture<E> invokeOnPartition(Operation operation)
protected final int getPartitionId(Data key)
protected boolean preDestroy()
protected void postDestroy()
public final NodeEngine getNodeEngine()
HazelcastInstanceNotActiveException
- if NodeEngine not active or DistributedObject destroyed.protected void throwNotActiveException()
public final S getService()
HazelcastInstanceNotActiveException
- if object is destroyed or HazelcastInstance shutdown.public final OperationService getOperationService()
HazelcastInstanceNotActiveException
- if object is destroyed or HazelcastInstance shutdown.public abstract String getServiceName()
DistributedObject
getServiceName
in interface DistributedObject
public final void invalidate()
Copyright © 2018 Hazelcast, Inc.. All rights reserved.