E - the type of elements in this queuepublic class ClientTxnQueueProxy<E> extends Object implements TransactionalQueue<E>
TransactionalQueue.| Constructor and Description |
|---|
ClientTxnQueueProxy(String name,
ClientTransactionContext transactionContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
destroy()
Destroys this object cluster-wide.
|
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, getName, 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 getServiceName()
DistributedObjectgetServiceName in interface DistributedObjectprotected String getTransactionId()
public final void destroy()
DistributedObjectdestroy in interface DistributedObjectpublic String getName()
DistributedObjectDistributedObjectUtil.getName(DistributedObject)
because this might be also a PrefixedDistributedObject.getName 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 © 2017 Hazelcast, Inc.. All Rights Reserved.