#include <SemanticState.h>
Inherits qpid::sys::OutputTask.
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) |
Queue::shared_ptr qpid::broker::SemanticState::getQueue | ( | const std::string & | name | ) | const |
Get named queue, never returns 0.
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 | |||
) |
tagInOut | - if empty it is updated with the generated token. |