com.hazelcast.impl

Class QProxyImpl

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue

com.hazelcast.impl.QProxyImpl

All Implemented Interfaces:

HazelcastInstanceAware, ICollection, Instance, IQueue, HazelcastInstanceAwareInstance, QProxy, DataSerializable, Serializable, Iterable, Collection, BlockingQueue, Queue

public class QProxyImpl
extends AbstractQueue
implements QProxy, HazelcastInstanceAwareInstance, DataSerializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.core.Instance

Instance.InstanceType

Constructor Summary

Constructors

Constructor and Description
QProxyImpl()

Method Summary

Methods

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)

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains, remove

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, isEmpty, removeAll, retainAll, toArray, toArray

Constructor Detail

QProxyImpl

public QProxyImpl()

Method Detail

getFactory

public FactoryImpl getFactory()

getLongName

public String getLongName()

Specified by:

getLongName in interface QProxy

setHazelcastInstance

public void setHazelcastInstance(HazelcastInstance hazelcastInstance)

Specified by:

setHazelcastInstance in interface HazelcastInstanceAware

getId

public Object getId()

Description copied from interface: Instance

Returns the unique id for this instance.

Specified by:

getId in interface Instance

Returns:

id the of this instance

toString

public String toString()

Overrides:

toString in class AbstractCollection

equals

public boolean equals(Object o)

Specified by:

equals in interface Collection

Overrides:

equals in class Object

hashCode

public int hashCode()

Specified by:

hashCode in interface Collection

Overrides:

hashCode in class Object

writeData

public void writeData(DataOutput out)
               throws IOException

Specified by:

writeData in interface DataSerializable

Throws:

IOException

readData

public void readData(DataInput in)
              throws IOException

Specified by:

readData in interface DataSerializable

Throws:

IOException

getLocalQueueStats

public LocalQueueStats getLocalQueueStats()

Specified by:

getLocalQueueStats in interface IQueue

iterator

public Iterator iterator()

Specified by:

iterator in interface Iterable

Specified by:

iterator in interface Collection

Specified by:

iterator in class AbstractCollection

size

public int size()

Specified by:

size in interface Collection

Specified by:

size in class AbstractCollection

addItemListener

public void addItemListener(ItemListener listener,
                   boolean includeValue)

Description copied from interface: ICollection

Adds an item listener for this collection. Listener will get notified for all collection add/remove events.

Specified by:

addItemListener in interface ICollection

Parameters:

listener - item listener

includeValue - true updated item should be passed to the item listener, false otherwise.

removeItemListener

public void removeItemListener(ItemListener listener)

Description copied from interface: ICollection

Removes the specified item listener. Returns silently if the specified listener is not added before.

Specified by:

removeItemListener in interface ICollection

Parameters:

listener - item listener for this collection

getName

public String getName()

Description copied from interface: ICollection

Returns the name of this collection

Specified by:

getName in interface ICollection

Returns:

name of this collection

drainTo

public int drainTo(Collection c)

Specified by:

drainTo in interface BlockingQueue

drainTo

public int drainTo(Collection c,
          int maxElements)

Specified by:

drainTo in interface BlockingQueue

destroy

public void destroy()

Description copied from interface: Instance

Destroys this instance cluster-wide. Clears and releases all resources for this instance.

Specified by:

destroy in interface Instance

getInstanceType

public Instance.InstanceType getInstanceType()

Description copied from interface: Instance

Returns instance type such as map, set, list, lock, topic, multimap, id generator

Specified by:

getInstanceType in interface Instance

Returns:

instance type

offer

public boolean offer(Object o)

Specified by:

offer in interface BlockingQueue

Specified by:

offer in interface Queue

offer

public boolean offer(Object obj,
            long timeout,
            TimeUnit unit)
              throws InterruptedException

Specified by:

offer in interface BlockingQueue

Throws:

InterruptedException

put

public void put(Object obj)
         throws InterruptedException

Specified by:

put in interface BlockingQueue

Throws:

InterruptedException

poll

public Object poll()

Specified by:

poll in interface Queue

poll

public Object poll(long timeout,
          TimeUnit unit)
            throws InterruptedException

Specified by:

poll in interface BlockingQueue

Throws:

InterruptedException

take

public Object take()
            throws InterruptedException

Specified by:

take in interface BlockingQueue

Throws:

InterruptedException

remainingCapacity

public int remainingCapacity()

Specified by:

remainingCapacity in interface BlockingQueue

peek

public Object peek()

Specified by:

peek in interface Queue

getQueueOperationCounter

public QueueOperationsCounter getQueueOperationCounter()

Specified by:

getQueueOperationCounter in interface QProxy