E - public class TransactionalQueueProxy<E> extends TransactionalQueueProxySupport implements TransactionalQueue<E>
config, name, partitionId, txPARTITIONING_STRATEGY| Constructor and Description |
|---|
TransactionalQueueProxy(NodeEngine nodeEngine,
QueueService service,
String name,
TransactionSupport tx) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
offer(E e)
Inserts the specified element into this queue if it is possible to do
so immediately without violating capacity restrictions, returning
true upon success and false if no space is currently
available.
|
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.
|
E |
take()
Retrieves and removes the head of this queue, waiting if necessary
until an element becomes available.
|
String |
toString() |
checkTransactionState, getName, getServiceName, offerInternal, peekInternal, pollInternal, sizedestroy, equals, getId, getNameAsPartitionAwareData, getNodeEngine, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveExceptionclone, finalize, getClass, notify, notifyAll, wait, wait, waitsizedestroy, getId, getName, getPartitionKey, getServiceNamepublic TransactionalQueueProxy(NodeEngine nodeEngine, QueueService service, String name, TransactionSupport tx)
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 determining 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 String toString()
toString in class AbstractDistributedObject<QueueService>Copyright © 2014 Hazelcast, Inc.. All Rights Reserved.