Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET Apache Qpid Documentation
Public Member Functions | List of all members
qpid::client::no_keyword::Session_0_10 Class Reference

AMQP 0-10 synchronous session API. More...

#include <qpid/client/no_keyword/Session_0_10.h>

Public Member Functions

 Session_0_10 ()
 
QPID_CLIENT_INLINE_EXTERN Session_0_10 (const SessionBase_0_10 &other)
 
QPID_CLIENT_INLINE_EXTERN
Session_0_10
operator= (const SessionBase_0_10 &other)
 
void executionSync (bool sync=true)
 
void executionResult (const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=true)
 
void executionException (uint16_t errorCode=0, const SequenceNumber &commandId=SequenceNumber(), uint8_t classCode=0, uint8_t commandCode=0, uint8_t fieldIndex=0, const std::string &description=std::string(), const FieldTable &errorInfo=FieldTable(), bool sync=true)
 
void messageTransfer (const std::string &destination=std::string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const Message &content=Message(std::string()), bool sync=true)
 
void messageAccept (const SequenceSet &transfers=SequenceSet(), bool sync=true)
 
void messageReject (const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=true)
 
void messageRelease (const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=true)
 
qpid::framing::MessageAcquireResult messageAcquire (const SequenceSet &transfers=SequenceSet(), bool sync=true)
 
qpid::framing::MessageResumeResult messageResume (const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=true)
 
void messageSubscribe (const std::string &queue=std::string(), const std::string &destination=std::string(), uint8_t acceptMode=0, uint8_t acquireMode=0, bool exclusive=false, const std::string &resumeId=std::string(), uint64_t resumeTtl=0, const FieldTable &arguments=FieldTable(), bool sync=true)
 
void messageCancel (const std::string &destination=std::string(), bool sync=true)
 
void messageSetFlowMode (const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=true)
 
void messageFlow (const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=true)
 
void messageFlush (const std::string &destination=std::string(), bool sync=true)
 
void messageStop (const std::string &destination=std::string(), bool sync=true)
 
void txSelect (bool sync=true)
 
void txCommit (bool sync=true)
 
void txRollback (bool sync=true)
 
void dtxSelect (bool sync=true)
 
qpid::framing::XaResult dtxStart (const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=true)
 
qpid::framing::XaResult dtxEnd (const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=true)
 
qpid::framing::XaResult dtxCommit (const Xid &xid=Xid(), bool onePhase=false, bool sync=true)
 
void dtxForget (const Xid &xid=Xid(), bool sync=true)
 
qpid::framing::DtxGetTimeoutResult dtxGetTimeout (const Xid &xid=Xid(), bool sync=true)
 
qpid::framing::XaResult dtxPrepare (const Xid &xid=Xid(), bool sync=true)
 
qpid::framing::DtxRecoverResult dtxRecover (bool sync=true)
 
qpid::framing::XaResult dtxRollback (const Xid &xid=Xid(), bool sync=true)
 
void dtxSetTimeout (const Xid &xid=Xid(), uint32_t timeout=0, bool sync=true)
 
void exchangeDeclare (const std::string &exchange=std::string(), const std::string &type=std::string(), const std::string &alternateExchange=std::string(), bool passive=false, bool durable=false, bool autoDelete=false, const FieldTable &arguments=FieldTable(), bool sync=true)
 
void exchangeDelete (const std::string &exchange=std::string(), bool ifUnused=false, bool sync=true)
 
qpid::framing::ExchangeQueryResult exchangeQuery (const std::string &name=std::string(), bool sync=true)
 
void exchangeBind (const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), const FieldTable &arguments=FieldTable(), bool sync=true)
 
void exchangeUnbind (const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=true)
 
qpid::framing::ExchangeBoundResult exchangeBound (const std::string &exchange=std::string(), const std::string &queue=std::string(), const std::string &bindingKey=std::string(), const FieldTable &arguments=FieldTable(), bool sync=true)
 
void queueDeclare (const std::string &queue=std::string(), const std::string &alternateExchange=std::string(), bool passive=false, bool durable=false, bool exclusive=false, bool autoDelete=false, const FieldTable &arguments=FieldTable(), bool sync=true)
 
void queueDelete (const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=true)
 
void queuePurge (const std::string &queue=std::string(), bool sync=true)
 
qpid::framing::QueueQueryResult queueQuery (const std::string &queue=std::string(), bool sync=true)
 

Detailed Description

AMQP 0-10 synchronous session API.

Definition at line 40 of file Session_0_10.h.

Constructor & Destructor Documentation

qpid::client::no_keyword::Session_0_10::Session_0_10 ( )
QPID_CLIENT_INLINE_EXTERN qpid::client::no_keyword::Session_0_10::Session_0_10 ( const SessionBase_0_10 &  other)

Member Function Documentation

qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxCommit ( const Xid &  xid = Xid(),
bool  onePhase = false,
bool  sync = true 
)
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxEnd ( const Xid &  xid = Xid(),
bool  fail = false,
bool  suspend = false,
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::dtxForget ( const Xid &  xid = Xid(),
bool  sync = true 
)
qpid::framing::DtxGetTimeoutResult qpid::client::no_keyword::Session_0_10::dtxGetTimeout ( const Xid &  xid = Xid(),
bool  sync = true 
)
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxPrepare ( const Xid &  xid = Xid(),
bool  sync = true 
)
qpid::framing::DtxRecoverResult qpid::client::no_keyword::Session_0_10::dtxRecover ( bool  sync = true)
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxRollback ( const Xid &  xid = Xid(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::dtxSelect ( bool  sync = true)
void qpid::client::no_keyword::Session_0_10::dtxSetTimeout ( const Xid &  xid = Xid(),
uint32_t  timeout = 0,
bool  sync = true 
)
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxStart ( const Xid &  xid = Xid(),
bool  join = false,
bool  resume = false,
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::exchangeBind ( const std::string &  queue = std::string(),
const std::string &  exchange = std::string(),
const std::string &  bindingKey = std::string(),
const FieldTable &  arguments = FieldTable(),
bool  sync = true 
)
qpid::framing::ExchangeBoundResult qpid::client::no_keyword::Session_0_10::exchangeBound ( const std::string &  exchange = std::string(),
const std::string &  queue = std::string(),
const std::string &  bindingKey = std::string(),
const FieldTable &  arguments = FieldTable(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::exchangeDeclare ( const std::string &  exchange = std::string(),
const std::string &  type = std::string(),
const std::string &  alternateExchange = std::string(),
bool  passive = false,
bool  durable = false,
bool  autoDelete = false,
const FieldTable &  arguments = FieldTable(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::exchangeDelete ( const std::string &  exchange = std::string(),
bool  ifUnused = false,
bool  sync = true 
)
qpid::framing::ExchangeQueryResult qpid::client::no_keyword::Session_0_10::exchangeQuery ( const std::string &  name = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::exchangeUnbind ( const std::string &  queue = std::string(),
const std::string &  exchange = std::string(),
const std::string &  bindingKey = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::executionException ( uint16_t  errorCode = 0,
const SequenceNumber &  commandId = SequenceNumber(),
uint8_t  classCode = 0,
uint8_t  commandCode = 0,
uint8_t  fieldIndex = 0,
const std::string &  description = std::string(),
const FieldTable &  errorInfo = FieldTable(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::executionResult ( const SequenceNumber &  commandId = SequenceNumber(),
const std::string &  value = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::executionSync ( bool  sync = true)
void qpid::client::no_keyword::Session_0_10::messageAccept ( const SequenceSet &  transfers = SequenceSet(),
bool  sync = true 
)
qpid::framing::MessageAcquireResult qpid::client::no_keyword::Session_0_10::messageAcquire ( const SequenceSet &  transfers = SequenceSet(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageCancel ( const std::string &  destination = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageFlow ( const std::string &  destination = std::string(),
uint8_t  unit = 0,
uint32_t  value = 0,
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageFlush ( const std::string &  destination = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageReject ( const SequenceSet &  transfers = SequenceSet(),
uint16_t  code = 0,
const std::string &  text = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageRelease ( const SequenceSet &  transfers = SequenceSet(),
bool  setRedelivered = false,
bool  sync = true 
)
qpid::framing::MessageResumeResult qpid::client::no_keyword::Session_0_10::messageResume ( const std::string &  destination = std::string(),
const std::string &  resumeId = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageSetFlowMode ( const std::string &  destination = std::string(),
uint8_t  flowMode = 0,
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageStop ( const std::string &  destination = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageSubscribe ( const std::string &  queue = std::string(),
const std::string &  destination = std::string(),
uint8_t  acceptMode = 0,
uint8_t  acquireMode = 0,
bool  exclusive = false,
const std::string &  resumeId = std::string(),
uint64_t  resumeTtl = 0,
const FieldTable &  arguments = FieldTable(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::messageTransfer ( const std::string &  destination = std::string(),
uint8_t  acceptMode = 1,
uint8_t  acquireMode = 0,
const Message &  content = Message(std::string()),
bool  sync = true 
)
QPID_CLIENT_INLINE_EXTERN Session_0_10& qpid::client::no_keyword::Session_0_10::operator= ( const SessionBase_0_10 &  other)
void qpid::client::no_keyword::Session_0_10::queueDeclare ( const std::string &  queue = std::string(),
const std::string &  alternateExchange = std::string(),
bool  passive = false,
bool  durable = false,
bool  exclusive = false,
bool  autoDelete = false,
const FieldTable &  arguments = FieldTable(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::queueDelete ( const std::string &  queue = std::string(),
bool  ifUnused = false,
bool  ifEmpty = false,
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::queuePurge ( const std::string &  queue = std::string(),
bool  sync = true 
)
qpid::framing::QueueQueryResult qpid::client::no_keyword::Session_0_10::queueQuery ( const std::string &  queue = std::string(),
bool  sync = true 
)
void qpid::client::no_keyword::Session_0_10::txCommit ( bool  sync = true)
void qpid::client::no_keyword::Session_0_10::txRollback ( bool  sync = true)
void qpid::client::no_keyword::Session_0_10::txSelect ( bool  sync = true)

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

Qpid C++ API Reference
Generated on Tue Oct 28 2014 for Qpid C++ Client API by doxygen 1.8.5