com.hazelcast.collection.impl.txncollection

Class AbstractTransactionalCollectionProxy<S extends RemoteService,E>

java.lang.Object

com.hazelcast.spi.AbstractDistributedObject<S>

com.hazelcast.spi.TransactionalDistributedObject<S>

com.hazelcast.collection.impl.txncollection.AbstractTransactionalCollectionProxy<S,E>

All Implemented Interfaces:

DistributedObject

Direct Known Subclasses:

TransactionalListProxy, TransactionalSetProxy

public abstract class AbstractTransactionalCollectionProxy<S extends RemoteService,E>
extends TransactionalDistributedObject<S>

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<Long>	itemIdSet
protected String	name
protected int	partitionId

Fields inherited from class com.hazelcast.spi.TransactionalDistributedObject

tx

Fields inherited from class com.hazelcast.spi.AbstractDistributedObject

PARTITIONING_STRATEGY

Constructor Summary

Constructors

Constructor and Description
AbstractTransactionalCollectionProxy(String name, Transaction tx, NodeEngine nodeEngine, S service)

Method Summary

Methods

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()

Methods inherited from class com.hazelcast.spi.TransactionalDistributedObject

toObjectIfNeeded

Methods inherited from class com.hazelcast.spi.AbstractDistributedObject

destroy, equals, getDistributedObjectName, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, getServiceName, hashCode, invalidate, invokeOnPartition, postDestroy, preDestroy, throwNotActiveException, toData, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

name

protected final String name

partitionId

protected final int partitionId

itemIdSet

protected final Set<Long> itemIdSet

Constructor Detail

AbstractTransactionalCollectionProxy

public AbstractTransactionalCollectionProxy(String name,
                                    Transaction tx,
                                    NodeEngine nodeEngine,
                                    S service)

Method Detail

getCollection

protected abstract Collection<CollectionItem> getCollection()

getName

public String getName()

Description copied from interface: DistributedObject

Returns the unique name for this DistributedObject. The returned value will never be null. The suggested way for getting name is retrieving it through DistributedObjectUtil.getName(DistributedObject) because this might be also a PrefixedDistributedObject.

Returns:

the unique name for this object.

add

public boolean add(E e)

putToRecord

protected void putToRecord(CollectionTxnOperation operation)

remove

public boolean remove(E e)

size

public int size()

checkTransactionActive

protected void checkTransactionActive()

checkObjectNotNull

protected void checkObjectNotNull(Object o)