com.hazelcast.map.impl.tx

Class TransactionalMapProxySupport

java.lang.Object

com.hazelcast.spi.AbstractDistributedObject<S>

com.hazelcast.spi.TransactionalDistributedObject<MapService>

com.hazelcast.map.impl.tx.TransactionalMapProxySupport

All Implemented Interfaces:

DistributedObject, TransactionalObject

Direct Known Subclasses:

TransactionalMapProxy

public abstract class TransactionalMapProxySupport
extends TransactionalDistributedObject<MapService>
implements TransactionalObject

Base class contains proxy helper methods for TransactionalMapProxy

Field Summary

Fields

Modifier and Type	Field and Description
protected MapServiceContext	mapServiceContext
protected String	name
protected MapOperationProvider	operationProvider
protected PartitioningStrategy	partitionStrategy
protected RecordFactory	recordFactory
protected Map<Data,VersionedValue>	valueMap

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
TransactionalMapProxySupport(String name, MapService mapService, NodeEngine nodeEngine, Transaction transaction)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkTransactionState()
boolean	containsKeyInternal(Data key)
Object	getForUpdateInternal(Data key)
Object	getInternal(Data key)
String	getName() Returns the unique name for this DistributedObject.
String	getServiceName() Returns the service name for this object.
protected long	getTimeInMillis(long time, TimeUnit timeunit)
protected boolean	isEquals(Object value1, Object value2)
Data	putIfAbsentInternal(Data key, Data value)
Data	putInternal(Data key, Data value, long ttl, TimeUnit timeUnit)
boolean	removeIfSameInternal(Data key, Object value)
Data	removeInternal(Data key)
boolean	replaceIfSameInternal(Data key, Object oldValue, Data newValue)
Data	replaceInternal(Data key, Data value)
int	sizeInternal()

Methods inherited from class com.hazelcast.spi.TransactionalDistributedObject

toObjectIfNeeded

Methods inherited from class com.hazelcast.spi.AbstractDistributedObject

destroy, equals, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveException, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.core.DistributedObject

destroy, getPartitionKey

Field Detail

name

protected final String name

partitionStrategy

protected final PartitioningStrategy partitionStrategy

valueMap

protected final Map<Data,VersionedValue> valueMap

recordFactory

protected final RecordFactory recordFactory

operationProvider

protected final MapOperationProvider operationProvider

mapServiceContext

protected final MapServiceContext mapServiceContext

Constructor Detail

TransactionalMapProxySupport

public TransactionalMapProxySupport(String name,
                            MapService mapService,
                            NodeEngine nodeEngine,
                            Transaction transaction)

Method Detail

isEquals

protected boolean isEquals(Object value1,
               Object value2)

checkTransactionState

protected void checkTransactionState()

containsKeyInternal

public boolean containsKeyInternal(Data key)

getInternal

public Object getInternal(Data key)

getForUpdateInternal

public Object getForUpdateInternal(Data key)

sizeInternal

public int sizeInternal()

putInternal

public Data putInternal(Data key,
               Data value,
               long ttl,
               TimeUnit timeUnit)

putIfAbsentInternal

public Data putIfAbsentInternal(Data key,
                       Data value)

replaceInternal

public Data replaceInternal(Data key,
                   Data value)

replaceIfSameInternal

public boolean replaceIfSameInternal(Data key,
                            Object oldValue,
                            Data newValue)

removeInternal

public Data removeInternal(Data key)

removeIfSameInternal

public boolean removeIfSameInternal(Data key,
                           Object value)

getTimeInMillis

protected long getTimeInMillis(long time,
                   TimeUnit timeunit)

getName

public String getName()

Description copied from interface: DistributedObject

Returns the unique name for this DistributedObject. The returned value will never be null.

Specified by:

getName in interface DistributedObject

Returns:

the unique name for this object.

getServiceName

public final String getServiceName()

Description copied from interface: DistributedObject

Returns the service name for this object.

Specified by:

getServiceName in interface DistributedObject

Specified by:

getServiceName in class AbstractDistributedObject<MapService>

Returns:

the service name for this object.