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.
uint32_t setPrefetchSize (uint32_t size)
uint16_t setPrefetchCount (uint16_t n)
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)
bool get (DeliveryToken::shared_ptr token, Queue::shared_ptr queue, bool ackExpected)
void startTx ()
void commit (MessageStore *const store, bool completeOnCommit)
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)
void flow (bool active)
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 doOutput ()
void ackCumulative (DeliveryId deliveryTag)
void ackRange (DeliveryId deliveryTag, DeliveryId endTag)
void completed (DeliveryId deliveryTag, DeliveryId endTag)
void accepted (DeliveryId deliveryTag, DeliveryId endTag)


Detailed Description

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

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 May 15 22:23:37 2008 for Qpid by  doxygen 1.5.5