qpid::broker::SemanticState Class Reference

SemanticState holds the L3 and L4 state of an open session, whether attached to a channel or suspended. More...

#include <SemanticState.h>

Inherits qpid::sys::OutputTask.

Collaboration diagram for qpid::broker::SemanticState:

[legend]

List of all members.

Public Member Functions
	SemanticState (DeliveryAdapter &, SessionContext &)
SessionContext &	getSession ()
Queue::shared_ptr	getQueue (const std::string &name) const
	Get named queue, never returns 0.
bool	exists (const string &consumerTag)
void	consume (DeliveryToken::shared_ptr token, string &tagInOut, Queue::shared_ptr queue, bool nolocal, bool ackRequired, bool acquire, bool exclusive, const framing::FieldTable *=0)
void	cancel (const string &tag)
void	setWindowMode (const std::string &destination)
void	setCreditMode (const std::string &destination)
void	addByteCredit (const std::string &destination, uint32_t value)
void	addMessageCredit (const std::string &destination, uint32_t value)
void	flush (const std::string &destination)
void	stop (const std::string &destination)
void	startTx ()
void	commit (MessageStore *const store)
void	rollback ()
void	selectDtx ()
void	startDtx (const std::string &xid, DtxManager &mgr, bool join)
void	endDtx (const std::string &xid, bool fail)
void	suspendDtx (const std::string &xid)
void	resumeDtx (const std::string &xid)
void	recover (bool requeue)
DeliveryId	redeliver (QueuedMessage &msg, DeliveryToken::shared_ptr token)
void	acquire (DeliveryId first, DeliveryId last, DeliveryIds &acquired)
void	release (DeliveryId first, DeliveryId last, bool setRedelivered)
void	reject (DeliveryId first, DeliveryId last)
void	handle (boost::intrusive_ptr< Message > msg)
bool	hasOutput ()
bool	doOutput ()
void	completed (DeliveryId deliveryTag, DeliveryId endTag)
void	accepted (DeliveryId deliveryTag, DeliveryId endTag)
void	attached ()
void	detached ()
template<class F>
void	eachConsumer (F f)
Static Public Member Functions
static ConsumerImpl *	castToConsumerImpl (OutputTask *p)

---

Detailed Description

SemanticState holds the L3 and L4 state of an open session, whether attached to a channel or suspended.

Definition at line 59 of file SemanticState.h.

---

Member Function Documentation

Queue::shared_ptr qpid::broker::SemanticState::getQueue

(

const std::string &

name

)

const

Get named queue, never returns 0.

Returns:

: named queue

Exceptions:

		ChannelException if no queue of that name is found.
		ConnectionException if name="" and session has no default.

void qpid::broker::SemanticState::consume	(	DeliveryToken::shared_ptr	token,
		string &	tagInOut,
		Queue::shared_ptr	queue,
		bool	nolocal,
		bool	ackRequired,
		bool	acquire,
		bool	exclusive,
		const framing::FieldTable *	= 0
	)

Parameters:

tagInOut

- if empty it is updated with the generated token.

---

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

• /home/nsantos/projects/mrg-team/testing/magnum/f10/qpidc/qpid/cpp/src/qpid/broker/SemanticState.h