E - public class TransactionalQueueProxy<E> extends TransactionalQueueProxySupport implements TransactionalQueue<E>
config, name, partitionIdtxPARTITIONING_STRATEGY| Constructor and Description |
|---|
TransactionalQueueProxy(NodeEngine nodeEngine,
QueueService service,
String name,
Transaction 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.
|
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, sizetoObjectIfNeededdestroy, equals, getDistributedObjectName, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, invokeOnPartition, postDestroy, preDestroy, throwNotActiveException, toDataclone, finalize, getClass, notify, notifyAll, wait, wait, waitsizedestroy, getName, getPartitionKey, getServiceNamepublic TransactionalQueueProxy(NodeEngine nodeEngine, QueueService service, String name, Transaction 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 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 String toString()
toString in class AbstractDistributedObject<QueueService>Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.