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:

Collaboration graph
[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:

Generated on Thu Oct 16 13:38:14 2008 for Qpid by  doxygen 1.5.6