com.hazelcast.client.proxy.txn
public class ClientTxnQueueProxy<E> extends Object implements TransactionalQueue<E>
| Constructor and Description |
|---|
ClientTxnQueueProxy(String name,
ClientTransactionContext transactionContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
destroy()
Destroys this object cluster-wide.
|
Object |
getId()
Returns the unique id for this object.
|
String |
getName()
Returns the unique name for this DistributedObject.
|
String |
getPartitionKey()
Returns the key of the partition that this DistributedObject is assigned to.
|
String |
getServiceName()
Returns the service name for this object.
|
protected String |
getTransactionId() |
boolean |
offer(E e)
Inserts the specified element into this queue if it is possible to do
so immediately without violating capacity restrictions.
|
boolean |
offer(E e,
long timeout,
TimeUnit unit)
Inserts the specified element into this queue, waiting up to the
specified wait time if necessary for space to become available.
|
E |
peek() |
E |
peek(long timeout,
TimeUnit unit) |
E |
poll()
Retrieves and removes the head of this queue,
or returns null if this queue is empty.
|
E |
poll(long timeout,
TimeUnit unit)
Retrieves and removes the head of this queue, waiting up to the
specified wait time if necessary for an element to become available.
|
int |
size()
Returns the number of elements in this collection.
|
E |
take()
Retrieves and removes the head of this queue, waiting if necessary
until an element becomes available.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdestroy, getId, getPartitionKeypublic ClientTxnQueueProxy(String name, ClientTransactionContext transactionContext)
public boolean offer(E e)
TransactionalQueuepublic boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueueoffer in interface BaseQueue<E>offer in interface TransactionalQueue<E>e - the element to addtimeout - how long to wait before giving up, in units of
unitunit - a TimeUnit determines how to interpret the
timeout parameterInterruptedException - if interrupted while waitingpublic E take() throws InterruptedException
TransactionalQueuetake in interface BaseQueue<E>take in interface TransactionalQueue<E>InterruptedException - if interrupted while waitingpublic E poll()
TransactionalQueuepublic E poll(long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueuepoll in interface BaseQueue<E>poll in interface TransactionalQueue<E>timeout - how long to wait before giving up, in units of
unitunit - a TimeUnit determining how to interpret the
timeout parameterInterruptedException - if interrupted while waitingpublic E peek()
TransactionalQueuepeek in interface TransactionalQueue<E>public E peek(long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueuepeek in interface TransactionalQueue<E>InterruptedExceptionpublic int size()
TransactionalQueuepublic String getName()
DistributedObjectgetName in interface DistributedObjectpublic String getServiceName()
DistributedObjectgetServiceName in interface DistributedObjectprotected String getTransactionId()
public final void destroy()
DistributedObjectdestroy in interface DistributedObjectpublic Object getId()
DistributedObjectgetId in interface DistributedObjectpublic String getPartitionKey()
DistributedObjectIAtomicLong. For a partitioned data structure like an IMap,
the returned value will not be null, but otherwise undefined.getPartitionKey in interface DistributedObjectCopyright © 2015 Hazelcast, Inc.. All Rights Reserved.