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, toData
clone, 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(E e)
add
in interface Collection<E>
add
in interface BlockingQueue<E>
add
in interface Queue<E>
public boolean offer(E e)
BaseQueue
public void put(E e) throws InterruptedException
put
in interface BlockingQueue<E>
InterruptedException
public boolean offer(E e, long timeout, 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
unittimeUnit
- a TimeUnit determines how to interpret the
timeout parameterInterruptedException
- if interrupted while waitingpublic 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, 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
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()
IQueue
public 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 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>
public final String getName()
DistributedObject
DistributedObjectUtil.getName(DistributedObject)
because this might be also a PrefixedDistributedObject
.getName
in interface DistributedObject
public String addItemListener(ItemListener listener, boolean includeValue)
public boolean removeItemListener(String registrationId)
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.