com.hazelcast.collection.impl.txnqueue

Class TransactionalQueueProxySupport

java.lang.Object

com.hazelcast.spi.AbstractDistributedObject<QueueService>

com.hazelcast.collection.impl.txnqueue.TransactionalQueueProxySupport

All Implemented Interfaces:

DistributedObject, TransactionalObject

Direct Known Subclasses:

TransactionalQueueProxy

public abstract class TransactionalQueueProxySupport
extends AbstractDistributedObject<QueueService>
implements TransactionalObject

Provides support for proxy of the Transactional Queue.

Field Summary

Fields

Modifier and Type	Field and Description
protected QueueConfig	config
protected String	name
protected int	partitionId
protected Transaction	tx

Fields inherited from class com.hazelcast.spi.AbstractDistributedObject

PARTITIONING_STRATEGY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransactionalQueueProxySupport(NodeEngine nodeEngine, QueueService service, String name, Transaction tx)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkTransactionState()
String	getName() Returns the unique name for this DistributedObject.
String	getServiceName() Returns the service name for this object.
boolean	offerInternal(Data data, long timeout)
Data	peekInternal(long timeout)
Data	pollInternal(long timeout)
int	size()

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

tx

protected final Transaction tx

partitionId

protected final int partitionId

config

protected final QueueConfig config

Constructor Detail

TransactionalQueueProxySupport

protected TransactionalQueueProxySupport(NodeEngine nodeEngine,
                              QueueService service,
                              String name,
                              Transaction tx)

Method Detail

checkTransactionState

protected void checkTransactionState()

offerInternal

public boolean offerInternal(Data data,
                    long timeout)

pollInternal

public Data pollInternal(long timeout)

peekInternal

public Data peekInternal(long timeout)

size

public int size()

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<QueueService>

Returns:

the service name for this object.