public abstract class AbstractTransactionalCollectionProxy<S extends RemoteService,E> extends TransactionalDistributedObject<S>
Modifier and Type | Field and Description |
---|---|
protected Set<Long> |
itemIdSet |
protected String |
name |
protected OperationService |
operationService |
protected int |
partitionId |
tx
PARTITIONING_STRATEGY
Constructor and Description |
---|
AbstractTransactionalCollectionProxy(String name,
Transaction tx,
NodeEngine nodeEngine,
S service) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(E e) |
protected void |
checkObjectNotNull(Object o) |
protected void |
checkTransactionActive() |
protected abstract Collection<CollectionItem> |
getCollection() |
String |
getName()
Returns the unique name for this DistributedObject.
|
protected void |
putToRecord(CollectionTxnOperation operation) |
boolean |
remove(E e) |
int |
size() |
toObjectIfNeeded
destroy, equals, getDistributedObjectName, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, getServiceName, hashCode, invalidate, invokeOnPartition, isClusterVersionEqualTo, isClusterVersionGreaterOrEqual, isClusterVersionGreaterThan, isClusterVersionLessOrEqual, isClusterVersionLessThan, isClusterVersionUnknown, isClusterVersionUnknownOrGreaterOrEqual, isClusterVersionUnknownOrGreaterThan, isClusterVersionUnknownOrLessOrEqual, isClusterVersionUnknownOrLessThan, postDestroy, preDestroy, throwNotActiveException, toData, toString
protected final String name
protected final int partitionId
protected final OperationService operationService
public AbstractTransactionalCollectionProxy(String name, Transaction tx, NodeEngine nodeEngine, S service)
protected abstract Collection<CollectionItem> getCollection()
public String getName()
DistributedObject
DistributedObjectUtil.getName(DistributedObject)
because this might be also a PrefixedDistributedObject
.public boolean add(E e)
protected void putToRecord(CollectionTxnOperation operation)
public boolean remove(E e)
public int size()
protected void checkTransactionActive()
protected void checkObjectNotNull(Object o)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.