Concurrent, blocking, distributed, observable, client queue. More...

#include <IQueue.h>

Inheritance diagram for hazelcast::client::IQueue< E >:

Public Member Functions
std::string	addItemListener (ItemListener< E > &listener, bool includeValue)
	Adds an item listener for this collection. More...

bool	removeItemListener (const std::string &registrationId)
	Removes the specified item listener. More...

bool	offer (const E &element)
	Inserts the specified element into this queue. More...

void	put (const E &element)
	Puts the element into queue. More...

bool	offer (const E &element, long timeoutInMillis)
	Inserts the specified element into this queue. More...

boost::shared_ptr< E >	take ()

boost::shared_ptr< E >	poll (long timeoutInMillis)

int	remainingCapacity ()

bool	remove (const E &element)

bool	contains (const E &element)

size_t	drainTo (std::vector< E > &elements)
	Note that elements will be pushed_back to vector. More...

size_t	drainTo (std::vector< E > &elements, size_t maxElements)
	Note that elements will be pushed_back to vector. More...

boost::shared_ptr< E >	poll ()
	Returns immediately without waiting. More...

boost::shared_ptr< E >	peek ()
	Returns immediately without waiting. More...

int	size ()

bool	isEmpty ()

std::vector< E >	toArray ()

bool	containsAll (const std::vector< E > &elements)

bool	addAll (const std::vector< E > &elements)

bool	removeAll (const std::vector< E > &elements)

bool	retainAll (const std::vector< E > &elements)
	Removes the elements from this queue that are not available in given "elements" vector. More...

void	clear ()
	Removes all elements from queue.

Friends
class	HazelcastClient

class	adaptor::RawPointerQueue< E >

Detailed Description

template<typename E>
class hazelcast::client::IQueue< E >

Concurrent, blocking, distributed, observable, client queue.

Template Parameters

E item type

Member Function Documentation

template<typename E>

bool hazelcast::client::IQueue< E >::addAll ( const std::vector< E > & elements )

inline

Parameters

elements std::vector<E>

Returns: true if all elements given in vector can be added to queue.

Exceptions

IClassCastException if the type of the specified element is incompatible with the server side.

template<typename E>

std::string hazelcast::client::IQueue< E >::addItemListener	(	ItemListener< E > &	listener,
		bool	includeValue
	)

inline

Adds an item listener for this collection.

Listener will get notified for all collection add/remove events.

Warning 1: If listener should do a time consuming operation, off-load the operation to another thread. otherwise it will slow down the system.

Warning 2: Do not make a call to hazelcast. It can cause deadlock.

Parameters

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

Returns: returns registration id.

template<typename E>

bool hazelcast::client::IQueue< E >::contains ( const E & element )

inline

Parameters

element to be checked.

Returns: true if queue contains the element.

template<typename E>

bool hazelcast::client::IQueue< E >::containsAll ( const std::vector< E > & elements )

inline

Parameters

elements std::vector<E>

Returns: true if this queue contains all elements given in vector.

Exceptions

IClassCastException if the type of the specified element is incompatible with the server side.

template<typename E>

size_t hazelcast::client::IQueue< E >::drainTo ( std::vector< E > & elements )

inline

Note that elements will be pushed_back to vector.

Parameters

elements the vector that elements will be drained to.

Returns: number of elements drained.

template<typename E>

size_t hazelcast::client::IQueue< E >::drainTo	(	std::vector< E > &	elements,
		size_t	maxElements
	)

inline

Note that elements will be pushed_back to vector.

Parameters

maxElements	upper limit to be filled to vector.
elements	vector that elements will be drained to.

Returns: number of elements drained.

template<typename E>

bool hazelcast::client::IQueue< E >::isEmpty ( )

inline

Returns: true if queue is empty

template<typename E>

bool hazelcast::client::IQueue< E >::offer ( const E & element )

inline

Inserts the specified element into this queue.

Parameters

element to add

Returns: true if the element was added to this queue, else false

Exceptions

IClassCastException if the type of the specified element is incompatible with the server side.

template<typename E>

bool hazelcast::client::IQueue< E >::offer	(	const E &	element,
		long	timeoutInMillis
	)

inline

Inserts the specified element into this queue.

If queue is full waits for space to became available for specified time.

Parameters

element	to add
timeoutInMillis	how long to wait before giving up, in units of

Returns: true if successful, or false if the specified waiting time elapses before space is available

template<typename E>

boost::shared_ptr<E> hazelcast::client::IQueue< E >::peek ( )

inline

Returns immediately without waiting.

Returns: head of queue without removing it. If not available returns empty constructed shared_ptr.

template<typename E>

boost::shared_ptr<E> hazelcast::client::IQueue< E >::poll ( long timeoutInMillis )

inline

Parameters

timeoutInMillis time to wait if item is not available.

Returns: the head of the queue. If queue is empty waits for specified time.

template<typename E>

boost::shared_ptr<E> hazelcast::client::IQueue< E >::poll ( )

inline

Returns immediately without waiting.

Returns: removes head of the queue and returns it to user . If not available returns empty constructed shared_ptr.

template<typename E>

void hazelcast::client::IQueue< E >::put ( const E & element )

inline

Puts the element into queue.

If queue is full waits for space to became available.

template<typename E>

int hazelcast::client::IQueue< E >::remainingCapacity ( )

inline

Returns: remaining capacity

template<typename E>

bool hazelcast::client::IQueue< E >::remove ( const E & element )

inline

Parameters

element to be removed.

Returns: true if element removed successfully.

template<typename E>

bool hazelcast::client::IQueue< E >::removeAll ( const std::vector< E > & elements )

inline

Parameters

elements std::vector<E>

Returns: true if all elements are removed successfully.

Exceptions

IClassCastException if the type of the specified element is incompatible with the server side.

template<typename E>

bool hazelcast::client::IQueue< E >::removeItemListener ( const std::string & registrationId )

inline

Removes the specified item listener.

Returns silently if the specified listener is not added before.

Parameters

registrationId Id of listener registration.

Returns: true if registration is removed, false otherwise

template<typename E>

bool hazelcast::client::IQueue< E >::retainAll ( const std::vector< E > & elements )

inline

Removes the elements from this queue that are not available in given "elements" vector.

Parameters

elements std::vector<E>

Returns: true if operation is successful.

Exceptions

IClassCastException if the type of the specified element is incompatible with the server side.

template<typename E>

int hazelcast::client::IQueue< E >::size ( )

inline

Returns: size of this distributed queue

template<typename E>

boost::shared_ptr<E> hazelcast::client::IQueue< E >::take ( )

inline

Returns: the head of the queue. If queue is empty waits for an item to be added.

template<typename E>

std::vector<E> hazelcast::client::IQueue< E >::toArray ( )

inline

Returns: all elements as std::vector

The documentation for this class was generated from the following file:

hazelcast/include/hazelcast/client/IQueue.h

Public Member Functions

Friends

Detailed Description

template<typename E> class hazelcast::client::IQueue< E >

Member Function Documentation

template<typename E>
class hazelcast::client::IQueue< E >