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, toData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
remainingCapacity
clear, equals, hashCode, isEmpty, parallelStream, removeIf, size, spliterator, stream
addItemListener, getName, removeItemListener
destroy, getPartitionKey, getServiceName
initialize
public QueueProxyImpl(String name, QueueService queueService, NodeEngine nodeEngine, QueueConfig config)
public LocalQueueStats getLocalQueueStats()
IQueue
getLocalQueueStats
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)
BaseQueue
true
upon success and false
if no space is currently
available.public void put(@Nonnull E e) throws InterruptedException
put
in interface BlockingQueue<E>
InterruptedException
public boolean offer(@Nonnull E e, long timeout, @Nonnull TimeUnit timeUnit) throws InterruptedException
BaseQueue
offer
in interface BaseQueue<E>
offer
in interface BlockingQueue<E>
e
- the element to addtimeout
- how long to wait before giving up, in units of
unit
timeUnit
- 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
IQueue
take
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
IQueue
poll
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
unit
timeUnit
- 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()
IQueue
null
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 InitializingObject
public int getPartitionId()
public boolean isEmpty()
public int size()
public int remainingCapacity()
public void clear()
protected void checkObjectNotNull(Object o)
public final String getServiceName()
DistributedObject
getServiceName
in interface DistributedObject
getServiceName
in class AbstractDistributedObject<QueueService>
@Nonnull public final String getName()
DistributedObject
DistributedObjectUtil.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.