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) |
void |
destroy() |
int |
drainTo(Collection<? super E> objects) |
int |
drainTo(Collection<? super E> objects,
int i) |
boolean |
equals(Object o) |
Object |
getId() |
Instance.InstanceType |
getInstanceType() |
LocalQueueStats |
getLocalQueueStats() |
String |
getName() |
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) |
int |
size() |
E |
take() |
String |
toString() |
contains, containsAll, isEmpty, removeAll, retainAll, toArray, toArrayclone, finalize, getClass, notify, notifyAll, wait, wait, waitadd, containsaddAll, clear, containsAll, isEmpty, removeAll, retainAll, toArray, toArrayprotected final ProxyHelper proxyHelper
protected final String name
public QueueClientProxy(HazelcastClient hazelcastClient, String name)
public String getName()
getName in interface ICollection<E>public Instance.InstanceType getInstanceType()
getInstanceType in interface Instancepublic String toString()
toString in class AbstractCollection<E>public int hashCode()
hashCode in interface Collection<E>hashCode in class Objectpublic 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>InterruptedExceptionpublic E poll(long l, TimeUnit timeUnit) throws InterruptedException
poll in interface BlockingQueue<E>InterruptedExceptionpublic E take() throws InterruptedException
take in interface BlockingQueue<E>InterruptedExceptionpublic void put(E e) throws InterruptedException
put in interface BlockingQueue<E>InterruptedExceptionpublic 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 Objectpublic 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)
addItemListener in interface ICollection<E>public void removeItemListener(ItemListener<E> listener)
removeItemListener in interface ICollection<E>Copyright © 2019 Hazel Bilisim Ltd.. All rights reserved.