E - public class QueueProxyImpl<E> extends AbstractDistributedObject<QueueService> implements IQueue<E>, InitializingObject
PARTITIONING_STRATEGY| Constructor and Description |
|---|
QueueProxyImpl(String name,
QueueService queueService,
NodeEngine nodeEngine,
QueueConfig config) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
add(E e) |
boolean |
addAll(Collection<? extends E> es) |
String |
addItemListener(ItemListener listener,
boolean includeValue) |
protected void |
checkObjectNotNull(Object o) |
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.
|
int |
getPartitionId() |
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.
|
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.
|
Object[] |
toArray() |
<T> T[] |
toArray(T[] ts) |
String |
toString() |
destroy, equals, getDistributedObjectName, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, invokeOnPartition, isClusterVersionEqualTo, isClusterVersionGreaterOrEqual, isClusterVersionGreaterThan, isClusterVersionLessOrEqual, isClusterVersionLessThan, isClusterVersionUnknown, isClusterVersionUnknownOrGreaterOrEqual, isClusterVersionUnknownOrGreaterThan, isClusterVersionUnknownOrLessOrEqual, isClusterVersionUnknownOrLessThan, postDestroy, preDestroy, throwNotActiveException, toDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitremainingCapacityclear, equals, hashCode, isEmpty, parallelStream, removeIf, size, spliterator, streamaddItemListener, getName, removeItemListenerdestroy, getPartitionKey, getServiceNameinitializepublic QueueProxyImpl(String name, QueueService queueService, NodeEngine nodeEngine, QueueConfig config)
public LocalQueueStats getLocalQueueStats()
IQueuegetLocalQueueStats in interface IQueue<E>public boolean add(E e)
add in interface Collection<E>add in interface BlockingQueue<E>add in interface Queue<E>public boolean offer(E e)
BaseQueuepublic void put(E e) throws InterruptedException
put in interface BlockingQueue<E>InterruptedExceptionpublic boolean offer(E e, long timeout, TimeUnit timeUnit) throws InterruptedException
BaseQueueoffer in interface BaseQueue<E>offer in interface BlockingQueue<E>e - the element to addtimeout - how long to wait before giving up, in units of
unittimeUnit - a TimeUnit determines 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 boolean remove(Object o)
remove in interface Collection<E>remove in interface BlockingQueue<E>public boolean contains(Object o)
contains in interface Collection<E>contains in interface BlockingQueue<E>public int drainTo(Collection<? super E> objects)
drainTo in interface BlockingQueue<E>public int drainTo(Collection<? super E> objects, int i)
drainTo in interface BlockingQueue<E>public E poll()
IQueuepublic Object[] toArray()
toArray in interface Collection<E>public <T> T[] toArray(T[] ts)
toArray in interface Collection<E>public boolean containsAll(Collection<?> objects)
containsAll in interface Collection<E>public boolean addAll(Collection<? extends E> es)
addAll in interface Collection<E>public boolean removeAll(Collection<?> objects)
removeAll in interface Collection<E>public boolean retainAll(Collection<?> objects)
retainAll in interface Collection<E>public String toString()
toString in class AbstractDistributedObject<QueueService>public void initialize()
initialize in interface InitializingObjectpublic int getPartitionId()
public boolean isEmpty()
public int size()
public int remainingCapacity()
public void clear()
protected void checkObjectNotNull(Object o)
public final String getServiceName()
DistributedObjectgetServiceName in interface DistributedObjectgetServiceName in class AbstractDistributedObject<QueueService>public final String getName()
DistributedObjectDistributedObjectUtil.getName(DistributedObject)
because this might be also a PrefixedDistributedObject.getName in interface DistributedObjectpublic String addItemListener(ItemListener listener, boolean includeValue)
public boolean removeItemListener(String registrationId)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.