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) |
UUID |
addItemListener(ItemListener<E> 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(UUID 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(@Nonnull E e)
add in interface Collection<E>add in interface BlockingQueue<E>add in interface Queue<E>public boolean offer(@Nonnull E e)
BaseQueuetrue upon success and false if no space is currently
available.public void put(@Nonnull E e) throws InterruptedException
put in interface BlockingQueue<E>InterruptedExceptionpublic boolean offer(@Nonnull E e, long timeout, @Nonnull 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 parametertrue if successful, or false if
the specified waiting time elapses before space is availableInterruptedException - if interrupted while waiting@Nonnull public 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, @Nonnull 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 parameternull if the
specified waiting time elapses before an element is availableInterruptedException - if interrupted while waitingpublic boolean remove(@Nonnull Object o)
remove in interface Collection<E>remove in interface BlockingQueue<E>public boolean contains(@Nonnull Object o)
contains in interface Collection<E>contains in interface BlockingQueue<E>public int drainTo(@Nonnull Collection<? super E> objects)
drainTo in interface BlockingQueue<E>public int drainTo(@Nonnull Collection<? super E> objects, int i)
drainTo in interface BlockingQueue<E>public E poll()
IQueuenull if this queue is empty.public Object[] toArray()
toArray in interface Collection<E>@Nonnull public <T> T[] toArray(@Nonnull T[] ts)
toArray in interface Collection<E>public boolean containsAll(@Nonnull Collection<?> objects)
containsAll in interface Collection<E>public boolean addAll(@Nonnull Collection<? extends E> es)
addAll in interface Collection<E>public boolean removeAll(@Nonnull Collection<?> objects)
removeAll in interface Collection<E>public boolean retainAll(@Nonnull 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>@Nonnull public final String getName()
DistributedObjectDistributedObjectUtil.getName(DistributedObject)
because this might be also a PrefixedDistributedObject.getName in interface DistributedObject@Nonnull public UUID addItemListener(@Nonnull ItemListener<E> listener, boolean includeValue)
Copyright © 2019 Hazelcast, Inc.. All rights reserved.