E - public class QueueProxyImpl<E> extends AbstractDistributedObject<QueueService> implements IQueue<E>, InitializingObject
PARTITIONING_STRATEGY| Constructor and Description |
|---|
QueueProxyImpl(String name,
QueueService queueService,
NodeEngine nodeEngine) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
add(E e) |
boolean |
addAll(Collection<? extends E> es) |
String |
addItemListener(ItemListener listener,
boolean includeValue) |
void |
clear() |
boolean |
contains(Object o) |
boolean |
containsAll(Collection<?> objects) |
int |
drainTo(Collection<? super E> objects) |
int |
drainTo(Collection<? super E> objects,
int i) |
E |
element() |
LocalQueueStats |
getLocalQueueStats()
Returns LocalQueueStats for this queue.
|
String |
getName()
Returns the unique name for this DistributedObject.
|
String |
getServiceName()
Returns the service name for this object.
|
void |
initialize() |
boolean |
isEmpty() |
Iterator<E> |
iterator() |
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 timeUnit)
Inserts the specified element into this queue, waiting up to the
specified wait time if necessary for space to become available.
|
E |
peek() |
E |
poll()
Retrieves and removes the head of this queue,
or returns null if this queue is empty.
|
E |
poll(long timeout,
TimeUnit timeUnit)
Retrieves and removes the head of this queue, waiting up to the
specified wait time if necessary for an element to become available.
|
void |
put(E e) |
int |
remainingCapacity() |
E |
remove() |
boolean |
remove(Object o) |
boolean |
removeAll(Collection<?> objects) |
boolean |
removeItemListener(String registrationId) |
boolean |
retainAll(Collection<?> objects) |
int |
size() |
E |
take()
Retrieves and removes the head of this queue, waiting if necessary
until an element becomes available.
|
protected void |
throwExceptionIfNull(Object o) |
Object[] |
toArray() |
<T> T[] |
toArray(T[] ts) |
String |
toString() |
destroy, equals, getId, getNameAsPartitionAwareData, getNodeEngine, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveExceptionclone, finalize, getClass, notify, notifyAll, wait, wait, waitequals, hashCodeaddItemListener, getName, removeItemListenerdestroy, getId, getPartitionKey, getServiceNameinitializepublic QueueProxyImpl(String name, QueueService queueService, NodeEngine nodeEngine)
public LocalQueueStats getLocalQueueStats()
IQueuegetLocalQueueStats in interface IQueue<E>public boolean offer(E e)
IQueuepublic void put(E e) throws InterruptedException
IQueueput in interface IQueue<E>put in interface BlockingQueue<E>InterruptedExceptionpublic boolean offer(E e, long timeout, TimeUnit timeUnit) throws InterruptedException
IQueueoffer in interface BaseQueue<E>offer in interface IQueue<E>offer in interface BlockingQueue<E>e - the element to addtimeout - how long to wait before giving up, in units of
unittimeUnit - a TimeUnit determining how to interpret the
timeout parameterInterruptedException - if interrupted while waitingpublic E take() throws InterruptedException
IQueuetake in interface BaseQueue<E>take in interface IQueue<E>take in interface BlockingQueue<E>InterruptedException - if interrupted while waitingpublic E poll(long timeout, TimeUnit timeUnit) throws InterruptedException
IQueuepoll in interface BaseQueue<E>poll in interface IQueue<E>poll in interface BlockingQueue<E>timeout - how long to wait before giving up, in units of
unittimeUnit - a TimeUnit determining how to interpret the
timeout parameterInterruptedException - if interrupted while waitingpublic int remainingCapacity()
IQueueremainingCapacity in interface IQueue<E>remainingCapacity in interface BlockingQueue<E>public boolean remove(Object o)
IQueueremove in interface IQueue<E>remove in interface Collection<E>remove in interface BlockingQueue<E>public boolean contains(Object o)
IQueuecontains in interface IQueue<E>contains in interface Collection<E>contains in interface BlockingQueue<E>public int drainTo(Collection<? super E> objects)
IQueuepublic int drainTo(Collection<? super E> objects, int i)
IQueuepublic E poll()
IQueuepublic Iterator<E> iterator()
IQueueThe view's iterator is a "weakly consistent" iterator, and guarantees to traverse elements as they existed upon construction of the iterator, and may (but is not guaranteed to) reflect any modifications subsequent to construction.
public <T> T[] toArray(T[] ts)
IQueuepublic boolean containsAll(Collection<?> objects)
IQueuecontainsAll in interface IQueue<E>containsAll in interface Collection<E>public boolean addAll(Collection<? extends E> es)
IQueuepublic boolean removeAll(Collection<?> objects)
IQueuepublic boolean retainAll(Collection<?> objects)
IQueuepublic void initialize()
initialize in interface InitializingObjectpublic boolean isEmpty()
public int size()
public void clear()
protected void throwExceptionIfNull(Object o)
public final String getServiceName()
DistributedObjectgetServiceName in interface DistributedObjectgetServiceName in class AbstractDistributedObject<QueueService>public final String getName()
DistributedObjectgetName in interface DistributedObjectpublic String addItemListener(ItemListener listener, boolean includeValue)
public boolean removeItemListener(String registrationId)
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.