public class QueueClientProxy<E> extends AbstractQueue<E> implements IQueue<E>
Instance.InstanceType
Modifier and Type | Field and Description |
---|---|
protected String |
name |
protected ProxyHelper |
proxyHelper |
Constructor and Description |
---|
QueueClientProxy(HazelcastClient hazelcastClient,
String name) |
Modifier and Type | Method and Description |
---|---|
void |
addItemListener(ItemListener<E> listener,
boolean includeValue)
Adds an item listener for this collection.
|
void |
destroy()
Destroys this instance cluster-wide.
|
int |
drainTo(Collection<? super E> objects) |
int |
drainTo(Collection<? super E> objects,
int i) |
boolean |
equals(Object o) |
Object |
getId()
Returns the unique id for this instance.
|
Instance.InstanceType |
getInstanceType()
Returns instance type such as map, set, list, lock, topic, multimap, id generator
|
LocalQueueStats |
getLocalQueueStats() |
String |
getName()
Returns the name of this collection
|
int |
hashCode() |
Iterator<E> |
iterator() |
boolean |
offer(E e) |
boolean |
offer(E e,
long l,
TimeUnit timeUnit) |
E |
peek() |
E |
poll() |
E |
poll(long l,
TimeUnit timeUnit) |
void |
put(E e) |
int |
remainingCapacity() |
boolean |
remove(Object o) |
void |
removeItemListener(ItemListener<E> listener)
Removes the specified item listener.
|
int |
size() |
E |
take() |
String |
toString() |
contains, containsAll, isEmpty, removeAll, retainAll, toArray, toArray
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
add, contains
addAll, clear, containsAll, isEmpty, removeAll, retainAll, toArray, toArray
protected final ProxyHelper proxyHelper
protected final String name
public QueueClientProxy(HazelcastClient hazelcastClient, String name)
public String getName()
ICollection
getName
in interface ICollection<E>
public Instance.InstanceType getInstanceType()
Instance
getInstanceType
in interface Instance
public void destroy()
Instance
public Object getId()
Instance
public String toString()
toString
in class AbstractCollection<E>
public int hashCode()
hashCode
in interface Collection<E>
hashCode
in class Object
public LocalQueueStats getLocalQueueStats()
getLocalQueueStats
in interface IQueue<E>
public boolean offer(E e)
public boolean offer(E e, long l, TimeUnit timeUnit) throws InterruptedException
offer
in interface BlockingQueue<E>
InterruptedException
public E poll(long l, TimeUnit timeUnit) throws InterruptedException
poll
in interface BlockingQueue<E>
InterruptedException
public E take() throws InterruptedException
take
in interface BlockingQueue<E>
InterruptedException
public void put(E e) throws InterruptedException
put
in interface BlockingQueue<E>
InterruptedException
public int remainingCapacity()
remainingCapacity
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 int size()
size
in interface Collection<E>
size
in class AbstractCollection<E>
public boolean equals(Object o)
equals
in interface Collection<E>
equals
in class Object
public boolean remove(Object o)
remove
in interface Collection<E>
remove
in interface BlockingQueue<E>
remove
in class AbstractCollection<E>
public Iterator<E> iterator()
iterator
in interface Iterable<E>
iterator
in interface Collection<E>
iterator
in class AbstractCollection<E>
public void addItemListener(ItemListener<E> listener, boolean includeValue)
ICollection
addItemListener
in interface ICollection<E>
listener
- item listenerincludeValue
- true updated item should be passed
to the item listener, false otherwise.public void removeItemListener(ItemListener<E> listener)
ICollection
removeItemListener
in interface ICollection<E>
listener
- item listener for this collectionCopyright © 2013 Hazelcast, Inc.. All rights reserved.