public class QProxyImpl extends AbstractQueue implements QProxy, HazelcastInstanceAwareInstance, DataSerializable
Instance.InstanceType
Constructor and Description |
---|
QProxyImpl() |
Modifier and Type | Method and Description |
---|---|
void |
addItemListener(ItemListener listener,
boolean includeValue)
Adds an item listener for this collection.
|
void |
destroy()
Destroys this instance cluster-wide.
|
int |
drainTo(Collection c) |
int |
drainTo(Collection c,
int maxElements) |
boolean |
equals(Object o) |
FactoryImpl |
getFactory() |
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 |
getLongName() |
String |
getName()
Returns the name of this collection
|
QueueOperationsCounter |
getQueueOperationCounter() |
int |
hashCode() |
Iterator |
iterator() |
boolean |
offer(Object o) |
boolean |
offer(Object obj,
long timeout,
TimeUnit unit) |
Object |
peek() |
Object |
poll() |
Object |
poll(long timeout,
TimeUnit unit) |
void |
put(Object obj) |
void |
readData(DataInput in) |
int |
remainingCapacity() |
void |
removeItemListener(ItemListener listener)
Removes the specified item listener.
|
void |
setHazelcastInstance(HazelcastInstance hazelcastInstance) |
int |
size() |
Object |
take() |
String |
toString() |
void |
writeData(DataOutput out) |
contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
add, contains, remove
addAll, clear, containsAll, isEmpty, removeAll, retainAll, toArray, toArray
public FactoryImpl getFactory()
public String getLongName()
getLongName
in interface QProxy
public void setHazelcastInstance(HazelcastInstance hazelcastInstance)
setHazelcastInstance
in interface HazelcastInstanceAware
public Object getId()
Instance
public String toString()
toString
in class AbstractCollection
public boolean equals(Object o)
equals
in interface Collection
equals
in class Object
public int hashCode()
hashCode
in interface Collection
hashCode
in class Object
public void writeData(DataOutput out) throws IOException
writeData
in interface DataSerializable
IOException
public void readData(DataInput in) throws IOException
readData
in interface DataSerializable
IOException
public LocalQueueStats getLocalQueueStats()
getLocalQueueStats
in interface IQueue
public Iterator iterator()
iterator
in interface Iterable
iterator
in interface Collection
iterator
in class AbstractCollection
public int size()
size
in interface Collection
size
in class AbstractCollection
public void addItemListener(ItemListener listener, boolean includeValue)
ICollection
addItemListener
in interface ICollection
listener
- item listenerincludeValue
- true updated item should be passed
to the item listener, false otherwise.public void removeItemListener(ItemListener listener)
ICollection
removeItemListener
in interface ICollection
listener
- item listener for this collectionpublic String getName()
ICollection
getName
in interface ICollection
public int drainTo(Collection c)
drainTo
in interface BlockingQueue
public int drainTo(Collection c, int maxElements)
drainTo
in interface BlockingQueue
public void destroy()
Instance
public Instance.InstanceType getInstanceType()
Instance
getInstanceType
in interface Instance
public boolean offer(Object o)
offer
in interface BlockingQueue
offer
in interface Queue
public boolean offer(Object obj, long timeout, TimeUnit unit) throws InterruptedException
offer
in interface BlockingQueue
InterruptedException
public void put(Object obj) throws InterruptedException
put
in interface BlockingQueue
InterruptedException
public Object poll(long timeout, TimeUnit unit) throws InterruptedException
poll
in interface BlockingQueue
InterruptedException
public Object take() throws InterruptedException
take
in interface BlockingQueue
InterruptedException
public int remainingCapacity()
remainingCapacity
in interface BlockingQueue
public QueueOperationsCounter getQueueOperationCounter()
getQueueOperationCounter
in interface QProxy
Copyright © 2013 Hazelcast, Inc.. All rights reserved.