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) |
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.
|
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, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveException
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
remainingCapacity
addItemListener, getName, removeItemListener
destroy, getPartitionKey, getServiceName
initialize
public QueueProxyImpl(String name, QueueService queueService, NodeEngine nodeEngine)
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
BaseQueue
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
BaseQueue
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()
BaseQueue
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 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
getName
in interface DistributedObject
public String addItemListener(ItemListener listener, boolean includeValue)
public boolean removeItemListener(String registrationId)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.