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

Inheritance diagram for activemq::core::SimplePriorityMessageDispatchChannel:

Public Member Functions
	SimplePriorityMessageDispatchChannel ()

virtual	~SimplePriorityMessageDispatchChannel ()

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

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

virtual bool	isEmpty () const

virtual bool	isClosed () const

virtual bool	isRunning () const

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

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

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

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

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

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

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

virtual int	size () const

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

virtual void	lock ()
	Locks the object.

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

virtual void	unlock ()
	Unlocks the object.

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

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

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

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

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

Public Member Functions inherited from activemq::core::MessageDispatchChannel
virtual	~MessageDispatchChannel ()

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

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

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.

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

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

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

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

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

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

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.

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

virtual void	lock ()=0
	Locks the object.

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

virtual void	unlock ()=0
	Unlocks the object.

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

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

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

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

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

Constructor & Destructor Documentation

◆ SimplePriorityMessageDispatchChannel()

activemq::core::SimplePriorityMessageDispatchChannel::SimplePriorityMessageDispatchChannel ( )

◆ ~SimplePriorityMessageDispatchChannel()

virtual activemq::core::SimplePriorityMessageDispatchChannel::~SimplePriorityMessageDispatchChannel ( )

virtual

Member Function Documentation

◆ clear()

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

virtual

Clear the Channel, all pending messages are removed.

Implements activemq::core::MessageDispatchChannel.

◆ close()

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

virtual

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

Implements activemq::core::MessageDispatchChannel.

◆ dequeue()

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

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.

Returns: null if we timeout or if the consumer is closed.

Exceptions

ActiveMQException

Implements activemq::core::MessageDispatchChannel.

◆ dequeueNoWait()

virtual Pointer< MessageDispatch > activemq::core::SimplePriorityMessageDispatchChannel::dequeueNoWait ( )

virtual

Used to get an enqueued message if there is one queued right now.

If there is no waiting message than this method returns Null.

Returns: a message if there is one in the queue.

Implements activemq::core::MessageDispatchChannel.

◆ enqueue()

virtual void activemq::core::SimplePriorityMessageDispatchChannel::enqueue ( const Pointer< MessageDispatch > & message )

virtual

Add a Message to the Channel behind all pending message.

Parameters

message - The message to add to the Channel.

Implements activemq::core::MessageDispatchChannel.

◆ enqueueFirst()

virtual void activemq::core::SimplePriorityMessageDispatchChannel::enqueueFirst ( const Pointer< MessageDispatch > & message )

virtual

Add a message to the front of the Channel.

Parameters

message - The Message to add to the front of the Channel.

Implements activemq::core::MessageDispatchChannel.

◆ isClosed()

virtual bool activemq::core::SimplePriorityMessageDispatchChannel::isClosed ( ) const

inlinevirtual

Returns: has the Queue been closed.

Implements activemq::core::MessageDispatchChannel.

◆ isEmpty()

virtual bool activemq::core::SimplePriorityMessageDispatchChannel::isEmpty ( ) const

virtual

Returns: true if there are no messages in the Channel.

Implements activemq::core::MessageDispatchChannel.

◆ isRunning()

virtual bool activemq::core::SimplePriorityMessageDispatchChannel::isRunning ( ) const

inlinevirtual

Returns: true if the Channel currently running and will dequeue message.

Implements activemq::core::MessageDispatchChannel.

◆ lock()

virtual void activemq::core::SimplePriorityMessageDispatchChannel::lock ( )

inlinevirtual

Locks the object.

Exceptions

RuntimeException if an error occurs while locking the object.

Implements decaf::util::concurrent::Synchronizable.

References decaf::util::concurrent::Mutex::lock().

◆ notify()

virtual void activemq::core::SimplePriorityMessageDispatchChannel::notify ( )

inlinevirtual

Signals a waiter on this object that it can now wake up and continue.

Must have this object locked before calling.

Exceptions

IllegalMonitorStateException	- if the current thread is not the owner of the the Synchronizable Object.
RuntimeException	if an error occurs while notifying one of the waiting threads.

Implements decaf::util::concurrent::Synchronizable.

References decaf::util::concurrent::Mutex::notify().

◆ notifyAll()

virtual void activemq::core::SimplePriorityMessageDispatchChannel::notifyAll ( )

inlinevirtual

Signals the waiters on this object that it can now wake up and continue.

Must have this object locked before calling.

Exceptions

IllegalMonitorStateException	- if the current thread is not the owner of the the Synchronizable Object.
RuntimeException	if an error occurs while notifying the waiting threads.

Implements decaf::util::concurrent::Synchronizable.

References decaf::util::concurrent::Mutex::notifyAll().

◆ peek()

virtual Pointer< MessageDispatch > activemq::core::SimplePriorityMessageDispatchChannel::peek ( ) const

virtual

Peek in the Queue and return the first message in the Channel without removing it from the channel.

Returns: a message if there is one in the queue.

Implements activemq::core::MessageDispatchChannel.

◆ removeAll()

virtual std::vector< Pointer< MessageDispatch > > activemq::core::SimplePriorityMessageDispatchChannel::removeAll ( )

virtual

Remove all messages that are currently in the Channel and return them as a list of Messages.

Returns: a list of Messages that was previously in the Channel.

Implements activemq::core::MessageDispatchChannel.

◆ size()

virtual int activemq::core::SimplePriorityMessageDispatchChannel::size ( ) const

virtual

Returns: the number of Messages currently in the Channel.

Implements activemq::core::MessageDispatchChannel.

◆ start()

virtual void activemq::core::SimplePriorityMessageDispatchChannel::start ( )

virtual

Starts dispatch of messages from the Channel.

Implements activemq::core::MessageDispatchChannel.

◆ stop()

virtual void activemq::core::SimplePriorityMessageDispatchChannel::stop ( )

virtual

Stops dispatch of message from the Channel.

Implements activemq::core::MessageDispatchChannel.

◆ tryLock()

virtual bool activemq::core::SimplePriorityMessageDispatchChannel::tryLock ( )

inlinevirtual

Attempts to Lock the object, if the lock is already held by another thread than this method returns false.

Returns: true if the lock was acquired, false if it is already held by another thread.

Exceptions

RuntimeException if an error occurs while locking the object.

Implements decaf::util::concurrent::Synchronizable.

References decaf::util::concurrent::Mutex::tryLock().

◆ unlock()

virtual void activemq::core::SimplePriorityMessageDispatchChannel::unlock ( )

inlinevirtual

Unlocks the object.

Exceptions

RuntimeException if an error occurs while unlocking the object.

Implements decaf::util::concurrent::Synchronizable.

References decaf::util::concurrent::Mutex::unlock().

◆ wait() [1/3]

virtual void activemq::core::SimplePriorityMessageDispatchChannel::wait ( )

inlinevirtual

Waits on a signal from this object, which is generated by a call to Notify.

Must have this object locked before calling.

Exceptions

RuntimeException	if an error occurs while waiting on the object.
InterruptedException	if the wait is interrupted before it completes.
IllegalMonitorStateException	- if the current thread is not the owner of the the Synchronizable Object.

Implements decaf::util::concurrent::Synchronizable.

References decaf::util::concurrent::Mutex::wait().

◆ wait() [2/3]

virtual void activemq::core::SimplePriorityMessageDispatchChannel::wait ( long long millisecs )

inlinevirtual

Waits on a signal from this object, which is generated by a call to Notify.

Must have this object locked before calling. This wait will timeout after the specified time interval.

Parameters

millisecs the time in milliseconds to wait, or WAIT_INIFINITE

Exceptions

RuntimeException	if an error occurs while waiting on the object.
InterruptedException	if the wait is interrupted before it completes.
IllegalMonitorStateException	- if the current thread is not the owner of the the Synchronizable Object.

Implements decaf::util::concurrent::Synchronizable.

References decaf::util::concurrent::Mutex::wait().

◆ wait() [3/3]

virtual void activemq::core::SimplePriorityMessageDispatchChannel::wait	(	long long	millisecs,
		int	nanos
	)

inlinevirtual

Waits on a signal from this object, which is generated by a call to Notify.

Must have this object locked before calling. This wait will timeout after the specified time interval. This method is similar to the one argument wait function except that it add a finer grained control over the amount of time that it waits by adding in the additional nanosecond argument.

NOTE: The ability to wait accurately at a nanosecond scale depends on the platform and OS that the Decaf API is running on, some systems do not provide an accurate enough clock to provide this level of granularity.

Parameters

millisecs	the time in milliseconds to wait, or WAIT_INIFINITE
nanos	additional time in nanoseconds with a range of 0-999999

Exceptions

IllegalArgumentException	if an error occurs or the nanos argument is not in the range of [0-999999]
RuntimeException	if an error occurs while waiting on the object.
InterruptedException	if the wait is interrupted before it completes.
IllegalMonitorStateException	- if the current thread is not the owner of the the Synchronizable Object.

Implements decaf::util::concurrent::Synchronizable.

References decaf::util::concurrent::Mutex::wait().

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

src/main/activemq/core/SimplePriorityMessageDispatchChannel.h

Public Member Functions

Constructor & Destructor Documentation

◆ SimplePriorityMessageDispatchChannel()

◆ ~SimplePriorityMessageDispatchChannel()

Member Function Documentation

◆ clear()

◆ close()

◆ dequeue()

◆ dequeueNoWait()

◆ enqueue()

◆ enqueueFirst()

◆ isClosed()

◆ isEmpty()

◆ isRunning()

◆ lock()

◆ notify()

◆ notifyAll()

◆ peek()

◆ removeAll()

◆ size()

◆ start()

◆ stop()

◆ tryLock()

◆ unlock()

◆ wait() [1/3]

◆ wait() [2/3]

◆ wait() [3/3]