E
- public class TransactionalQueueProxy<E> extends TransactionalQueueProxySupport implements TransactionalQueue<E>
config, name, partitionId, tx
PARTITIONING_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, size
destroy, equals, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveException
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
size
destroy, getName, getPartitionKey, getServiceName
public TransactionalQueueProxy(NodeEngine nodeEngine, QueueService service, String name, Transaction tx)
public boolean offer(E e)
TransactionalQueue
public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueue
offer
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
TransactionalQueue
take
in interface BaseQueue<E>
take
in interface TransactionalQueue<E>
InterruptedException
- if interrupted while waitingpublic E poll()
TransactionalQueue
public E poll(long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueue
poll
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()
TransactionalQueue
peek
in interface TransactionalQueue<E>
public E peek(long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueue
peek
in interface TransactionalQueue<E>
InterruptedException
public String toString()
toString
in class AbstractDistributedObject<QueueService>
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.