com.hazelcast.queue.impl.tx
Class TransactionalQueueProxySupport

java.lang.Object
  extended by com.hazelcast.spi.AbstractDistributedObject<QueueService>
      extended by com.hazelcast.queue.impl.tx.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
protected  QueueConfig config
           
protected  String name
           
protected  int partitionId
           
protected  TransactionSupport tx
           
 
Fields inherited from class com.hazelcast.spi.AbstractDistributedObject
PARTITIONING_STRATEGY
 
Constructor Summary
protected TransactionalQueueProxySupport(NodeEngine nodeEngine, QueueService service, String name, TransactionSupport tx)
           
 
Method Summary
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, getId, getNameAsPartitionAwareData, getNodeEngine, 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, getId, getPartitionKey
 

Field Detail

name

protected final String name

tx

protected final TransactionSupport tx

partitionId

protected final int partitionId

config

protected final QueueConfig config
Constructor Detail

TransactionalQueueProxySupport

protected TransactionalQueueProxySupport(NodeEngine nodeEngine,
                                         QueueService service,
                                         String name,
                                         TransactionSupport 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.


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.