#include <src/main/activemq/core/MessageDispatchChannel.h>

Inheritance diagram for activemq::core::MessageDispatchChannel:

Public Member Functions
virtual	~MessageDispatchChannel ()

virtual void	enqueue (const Pointer< MessageDispatch > &message)=0
	Add a Message to the Channel behind all pending message. More...

virtual void	enqueueFirst (const Pointer< MessageDispatch > &message)=0
	Add a message to the front of the Channel. More...

virtual bool	isEmpty () const =0

virtual bool	isClosed () const =0

virtual bool	isRunning () const =0

virtual Pointer< MessageDispatch >	dequeue (long long timeout)=0
	Used to get an enqueued message. More...

virtual Pointer< MessageDispatch >	dequeueNoWait ()=0
	Used to get an enqueued message if there is one queued right now. More...

virtual Pointer< MessageDispatch >	peek () const =0
	Peek in the Queue and return the first message in the Channel without removing it from the channel. More...

virtual void	start ()=0
	Starts dispatch of messages from the Channel. More...

virtual void	stop ()=0
	Stops dispatch of message from the Channel. More...

virtual void	close ()=0
	Close this channel no messages will be dispatched after this method is called. More...

virtual void	clear ()=0
	Clear the Channel, all pending messages are removed. More...

virtual int	size () const =0

virtual std::vector< Pointer < MessageDispatch > >	removeAll ()=0
	Remove all messages that are currently in the Channel and return them as a list of Messages. More...

Public Member Functions inherited from decaf::util::concurrent::Synchronizable
virtual	~Synchronizable ()

virtual void	lock ()=0
	Locks the object. More...

virtual bool	tryLock ()=0
	Attempts to Lock the object, if the lock is already held by another thread than this method returns false. More...

virtual void	unlock ()=0
	Unlocks the object. More...

virtual void	wait ()=0
	Waits on a signal from this object, which is generated by a call to Notify. More...

virtual void	wait (long long millisecs)=0
	Waits on a signal from this object, which is generated by a call to Notify. More...

virtual void	wait (long long millisecs, int nanos)=0
	Waits on a signal from this object, which is generated by a call to Notify. More...

virtual void	notify ()=0
	Signals a waiter on this object that it can now wake up and continue. More...

virtual void	notifyAll ()=0
	Signals the waiters on this object that it can now wake up and continue. More...

Constructor & Destructor Documentation

virtual activemq::core::MessageDispatchChannel::~MessageDispatchChannel ( )

virtual

Member Function Documentation

virtual void activemq::core::MessageDispatchChannel::clear ( )

pure virtual

Clear the Channel, all pending messages are removed.

Implemented in activemq::core::SimplePriorityMessageDispatchChannel, and activemq::core::FifoMessageDispatchChannel.

virtual void activemq::core::MessageDispatchChannel::close ( )

pure virtual

Close this channel no messages will be dispatched after this method is called.

Implemented in activemq::core::SimplePriorityMessageDispatchChannel, and activemq::core::FifoMessageDispatchChannel.

virtual Pointer<MessageDispatch> activemq::core::MessageDispatchChannel::dequeue ( long long timeout )

pure virtual

Used to get an enqueued message.

The amount of time this method blocks is based on the timeout value. - if timeout==-1 then it blocks until a message is received. - if timeout==0 then it it tries to not block at all, it returns a message if it is available - if timeout>0 then it blocks up to timeout amount of time. Expired messages will consumed by this method.