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

AMQP 0-10 session API with keyword arguments. More...

#include <qpid/client/AsyncSession_0_10.h>

Public Member Functions

 AsyncSession_0_10 ()
 
QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10 (const SessionBase_0_10 &other)
 
QPID_CLIENT_INLINE_EXTERN
AsyncSession_0_10
operator= (const SessionBase_0_10 &other)
 
 BOOST_PARAMETER_MEMFUN (Completion, executionSync, 0, 1, ExecutionSyncParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, executionResult, 0, 3, ExecutionResultParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, executionException, 0, 8, ExecutionExceptionParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageTransfer, 0, 5, MessageTransferParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageAccept, 0, 2, MessageAcceptParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageReject, 0, 4, MessageRejectParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageRelease, 0, 3, MessageReleaseParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::MessageAcquireResult >, messageAcquire, 0, 2, MessageAcquireParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::MessageResumeResult >, messageResume, 0, 3, MessageResumeParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageSubscribe, 0, 9, MessageSubscribeParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageCancel, 0, 2, MessageCancelParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageSetFlowMode, 0, 3, MessageSetFlowModeParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageFlow, 0, 4, MessageFlowParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageFlush, 0, 2, MessageFlushParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, messageStop, 0, 2, MessageStopParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, txSelect, 0, 1, TxSelectParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, txCommit, 0, 1, TxCommitParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, txRollback, 0, 1, TxRollbackParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, dtxSelect, 0, 1, DtxSelectParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxStart, 0, 4, DtxStartParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxEnd, 0, 4, DtxEndParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxCommit, 0, 3, DtxCommitParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, dtxForget, 0, 2, DtxForgetParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::DtxGetTimeoutResult >, dtxGetTimeout, 0, 2, DtxGetTimeoutParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxPrepare, 0, 2, DtxPrepareParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::DtxRecoverResult >, dtxRecover, 0, 1, DtxRecoverParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxRollback, 0, 2, DtxRollbackParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, dtxSetTimeout, 0, 3, DtxSetTimeoutParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, exchangeDeclare, 0, 8, ExchangeDeclareParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, exchangeDelete, 0, 3, ExchangeDeleteParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::ExchangeQueryResult >, exchangeQuery, 0, 2, ExchangeQueryParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, exchangeBind, 0, 5, ExchangeBindParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, exchangeUnbind, 0, 4, ExchangeUnbindParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::ExchangeBoundResult >, exchangeBound, 0, 5, ExchangeBoundParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, queueDeclare, 0, 8, QueueDeclareParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, queueDelete, 0, 4, QueueDeleteParameters)
 
 BOOST_PARAMETER_MEMFUN (Completion, queuePurge, 0, 2, QueuePurgeParameters)
 
 BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::QueueQueryResult >, queueQuery, 0, 2, QueueQueryParameters)
 
Completion executionSync (bool sync=false)
 
Completion executionResult (const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=false)
 
Completion 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=false)
 
Completion messageTransfer (const std::string &destination=std::string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const Message &content=Message(std::string()), bool sync=false)
 
Completion messageAccept (const SequenceSet &transfers=SequenceSet(), bool sync=false)
 
Completion messageReject (const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=false)
 
Completion messageRelease (const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=false)
 
TypedResult
< qpid::framing::MessageAcquireResult
messageAcquire (const SequenceSet &transfers=SequenceSet(), bool sync=false)
 
TypedResult
< qpid::framing::MessageResumeResult
messageResume (const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=false)
 
Completion 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=false)
 
Completion messageCancel (const std::string &destination=std::string(), bool sync=false)
 
Completion messageSetFlowMode (const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=false)
 
Completion messageFlow (const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=false)
 
Completion messageFlush (const std::string &destination=std::string(), bool sync=false)
 
Completion messageStop (const std::string &destination=std::string(), bool sync=false)
 
Completion txSelect (bool sync=false)
 
Completion txCommit (bool sync=false)
 
Completion txRollback (bool sync=false)
 
Completion dtxSelect (bool sync=false)
 
TypedResult
< qpid::framing::XaResult
dtxStart (const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=false)
 
TypedResult
< qpid::framing::XaResult
dtxEnd (const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=false)
 
TypedResult
< qpid::framing::XaResult
dtxCommit (const Xid &xid=Xid(), bool onePhase=false, bool sync=false)
 
Completion dtxForget (const Xid &xid=Xid(), bool sync=false)
 
TypedResult
< qpid::framing::DtxGetTimeoutResult
dtxGetTimeout (const Xid &xid=Xid(), bool sync=false)
 
TypedResult
< qpid::framing::XaResult
dtxPrepare (const Xid &xid=Xid(), bool sync=false)
 
TypedResult
< qpid::framing::DtxRecoverResult
dtxRecover (bool sync=false)
 
TypedResult
< qpid::framing::XaResult
dtxRollback (const Xid &xid=Xid(), bool sync=false)
 
Completion dtxSetTimeout (const Xid &xid=Xid(), uint32_t timeout=0, bool sync=false)
 
Completion 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=false)
 
Completion exchangeDelete (const std::string &exchange=std::string(), bool ifUnused=false, bool sync=false)
 
TypedResult
< qpid::framing::ExchangeQueryResult
exchangeQuery (const std::string &name=std::string(), bool sync=false)
 
Completion 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=false)
 
Completion exchangeUnbind (const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=false)
 
TypedResult
< 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=false)
 
Completion 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=false)
 
Completion queueDelete (const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=false)
 
Completion queuePurge (const std::string &queue=std::string(), bool sync=false)
 
TypedResult
< qpid::framing::QueueQueryResult
queueQuery (const std::string &queue=std::string(), bool sync=false)
 
SessionId getId () const
 Get the session ID. More...
 
void close ()
 Close the session. More...
 
void sync ()
 Synchronize the session: sync() waits until all commands issued on this session so far have been completed by the broker. More...
 
uint32_t timeout (uint32_t seconds)
 Set the timeout for this session. More...
 
void suspend ()
 Suspend the session - detach it from its connection. More...
 
void resume (Connection)
 Resume a suspended session with a new connection. More...
 
uint16_t getChannel () const
 Get the channel associated with this session. More...
 
void flush ()
 
void markCompleted (const framing::SequenceSet &ids, bool notifyPeer)
 
void markCompleted (const framing::SequenceNumber &id, bool cumulative, bool notifyPeer)
 
void sendCompletion ()
 
bool isValid () const
 
Connection getConnection ()
 

Protected Attributes

boost::shared_ptr< SessionImpl > impl
 

Detailed Description

AMQP 0-10 session API with keyword arguments.

This class provides the same set of functions as no_keyword::AsyncSession_0_10, but also allows parameters be passed using keywords. The keyword is the parameter name in the namespace "arg".

For example given the normal function "foo(int x=0, int y=0, int z=0)" you could call it in either of the following ways:

* session.foo(1,2,3); // Normal no keywords
* session.foo(arg::z=3, arg::x=1); // Keywords and a default
*

The keyword functions are easy to use but their declarations are hard to read. You may find it easier to read the documentation for no_keyword::AsyncSession_0_10 which provides the same set of functions using normal non-keyword declarations.

Publishing Messages

Exchanges

Configuring exchanges in session.exchangeDeclare

arg::durable=true

Default: false.

If durable=true, an exchange remains active even if the server is restarted. If durable=false, an exchange is purged when a server restarts.

arg::autoDelete=true

Default: false.

If autoDelete=true, deleting the last binding for an exchange also deletes the exchange.

arg::alternatExchange="my.exchange"

Default: none.

If an alternate exchange is specified, messages that can not be delivered to any queue are sent to the alternate exchange.

Queues

Configuring queues with session.queueDeclare

arg::durable=true

Default: false.

If durable=true, a queue remains active if the server is restarted. If durable=false, a queue and its contents are lost when a server restarts.


arg::autoDelete=true

Default: false.

If autoDelete=true, the queue is deleted when the last active Subscription to the Queue is canceled.


arg::exclusive=true

Default: false.

If exclusive=true, only the Session that created a queue can access it.


arg::alternateExchange="my.exchange"

Default: none.

If an alternate exchange is specified, messages are routed to it if (1) they are rejected by a client, or (2) they remain on the queue when it is deleted.


Accepting, Acquiring, Rejecting, or Releasing Messages

Transactions

Definition at line 189 of file AsyncSession_0_10.h.

Constructor & Destructor Documentation

qpid::client::AsyncSession_0_10::AsyncSession_0_10 ( )
inline

Definition at line 555 of file AsyncSession_0_10.h.

qpid::client::AsyncSession_0_10::AsyncSession_0_10 ( const SessionBase_0_10 other)
inline

Definition at line 556 of file AsyncSession_0_10.h.

Member Function Documentation

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
executionSync  ,
,
,
ExecutionSyncParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
executionResult  ,
,
,
ExecutionResultParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
executionException  ,
,
,
ExecutionExceptionParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageTransfer  ,
,
,
MessageTransferParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageAccept  ,
,
,
MessageAcceptParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageReject  ,
,
,
MessageRejectParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageRelease  ,
,
,
MessageReleaseParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::MessageAcquireResult ,
messageAcquire  ,
,
,
MessageAcquireParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::MessageResumeResult ,
messageResume  ,
,
,
MessageResumeParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageSubscribe  ,
,
,
MessageSubscribeParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageCancel  ,
,
,
MessageCancelParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageSetFlowMode  ,
,
,
MessageSetFlowModeParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageFlow  ,
,
,
MessageFlowParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageFlush  ,
,
,
MessageFlushParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
messageStop  ,
,
,
MessageStopParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
txSelect  ,
,
,
TxSelectParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
txCommit  ,
,
,
TxCommitParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
txRollback  ,
,
,
TxRollbackParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
dtxSelect  ,
,
,
DtxSelectParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::XaResult ,
dtxStart  ,
,
,
DtxStartParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::XaResult ,
dtxEnd  ,
,
,
DtxEndParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::XaResult ,
dtxCommit  ,
,
,
DtxCommitParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
dtxForget  ,
,
,
DtxForgetParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::DtxGetTimeoutResult ,
dtxGetTimeout  ,
,
,
DtxGetTimeoutParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::XaResult ,
dtxPrepare  ,
,
,
DtxPrepareParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::DtxRecoverResult ,
dtxRecover  ,
,
,
DtxRecoverParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::XaResult ,
dtxRollback  ,
,
,
DtxRollbackParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
dtxSetTimeout  ,
,
,
DtxSetTimeoutParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
exchangeDeclare  ,
,
,
ExchangeDeclareParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
exchangeDelete  ,
,
,
ExchangeDeleteParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::ExchangeQueryResult ,
exchangeQuery  ,
,
,
ExchangeQueryParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
exchangeBind  ,
,
,
ExchangeBindParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
exchangeUnbind  ,
,
,
ExchangeUnbindParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::ExchangeBoundResult ,
exchangeBound  ,
,
,
ExchangeBoundParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
queueDeclare  ,
,
,
QueueDeclareParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
queueDelete  ,
,
,
QueueDeleteParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( Completion  ,
queuePurge  ,
,
,
QueuePurgeParameters   
)
inline
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN ( TypedResult< qpid::framing::QueueQueryResult ,
queueQuery  ,
,
,
QueueQueryParameters   
)
inline
void qpid::client::SessionBase_0_10::close ( )
inherited

Close the session.

A session is automatically closed when all handles to it are destroyed.

TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxCommit ( const Xid xid = Xid(),
bool  onePhase = false,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxEnd ( const Xid xid = Xid(),
bool  fail = false,
bool  suspend = false,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::dtxForget ( const Xid xid = Xid(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::DtxGetTimeoutResult> qpid::client::no_keyword::AsyncSession_0_10::dtxGetTimeout ( const Xid xid = Xid(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxPrepare ( const Xid xid = Xid(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::DtxRecoverResult> qpid::client::no_keyword::AsyncSession_0_10::dtxRecover ( bool  sync = false)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxRollback ( const Xid xid = Xid(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::dtxSelect ( bool  sync = false)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::dtxSetTimeout ( const Xid xid = Xid(),
uint32_t  timeout = 0,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxStart ( const Xid xid = Xid(),
bool  join = false,
bool  resume = false,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_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 = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::ExchangeBoundResult> qpid::client::no_keyword::AsyncSession_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 = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_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 = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::exchangeDelete ( const std::string &  exchange = std::string(),
bool  ifUnused = false,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::ExchangeQueryResult> qpid::client::no_keyword::AsyncSession_0_10::exchangeQuery ( const std::string &  name = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::exchangeUnbind ( const std::string &  queue = std::string(),
const std::string &  exchange = std::string(),
const std::string &  bindingKey = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_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 = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::executionResult ( const SequenceNumber commandId = SequenceNumber(),
const std::string &  value = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::executionSync ( bool  sync = false)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

void qpid::client::SessionBase_0_10::flush ( )
inherited
uint16_t qpid::client::SessionBase_0_10::getChannel ( ) const
inherited

Get the channel associated with this session.

Connection qpid::client::SessionBase_0_10::getConnection ( )
inherited
SessionId qpid::client::SessionBase_0_10::getId ( ) const
inherited

Get the session ID.

bool qpid::client::SessionBase_0_10::isValid ( ) const
inherited
void qpid::client::SessionBase_0_10::markCompleted ( const framing::SequenceSet ids,
bool  notifyPeer 
)
inherited
void qpid::client::SessionBase_0_10::markCompleted ( const framing::SequenceNumber id,
bool  cumulative,
bool  notifyPeer 
)
inherited
Completion qpid::client::no_keyword::AsyncSession_0_10::messageAccept ( const SequenceSet transfers = SequenceSet(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::MessageAcquireResult> qpid::client::no_keyword::AsyncSession_0_10::messageAcquire ( const SequenceSet transfers = SequenceSet(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::messageCancel ( const std::string &  destination = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::messageFlow ( const std::string &  destination = std::string(),
uint8_t  unit = 0,
uint32_t  value = 0,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::messageFlush ( const std::string &  destination = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::messageReject ( const SequenceSet transfers = SequenceSet(),
uint16_t  code = 0,
const std::string &  text = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::messageRelease ( const SequenceSet transfers = SequenceSet(),
bool  setRedelivered = false,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::MessageResumeResult> qpid::client::no_keyword::AsyncSession_0_10::messageResume ( const std::string &  destination = std::string(),
const std::string &  resumeId = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::messageSetFlowMode ( const std::string &  destination = std::string(),
uint8_t  flowMode = 0,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::messageStop ( const std::string &  destination = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_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 = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_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 = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

AsyncSession_0_10 & qpid::client::AsyncSession_0_10::operator= ( const SessionBase_0_10 other)
inline

Definition at line 559 of file AsyncSession_0_10.h.

References qpid::client::SessionBase_0_10::impl.

Completion qpid::client::no_keyword::AsyncSession_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 = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::queueDelete ( const std::string &  queue = std::string(),
bool  ifUnused = false,
bool  ifEmpty = false,
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::queuePurge ( const std::string &  queue = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

TypedResult<qpid::framing::QueueQueryResult> qpid::client::no_keyword::AsyncSession_0_10::queueQuery ( const std::string &  queue = std::string(),
bool  sync = false 
)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

void qpid::client::SessionBase_0_10::resume ( Connection  )
inherited

Resume a suspended session with a new connection.

void qpid::client::SessionBase_0_10::sendCompletion ( )
inherited
void qpid::client::SessionBase_0_10::suspend ( )
inherited

Suspend the session - detach it from its connection.

void qpid::client::SessionBase_0_10::sync ( )
inherited

Synchronize the session: sync() waits until all commands issued on this session so far have been completed by the broker.

Note sync() is always synchronous, even on an AsyncSession object because that's almost always what you want. You can call AsyncSession::executionSync() directly in the unusual event that you want to do an asynchronous sync.

uint32_t qpid::client::SessionBase_0_10::timeout ( uint32_t  seconds)
inherited

Set the timeout for this session.

Completion qpid::client::no_keyword::AsyncSession_0_10::txCommit ( bool  sync = false)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::txRollback ( bool  sync = false)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Completion qpid::client::no_keyword::AsyncSession_0_10::txSelect ( bool  sync = false)
inherited

Referenced by BOOST_PARAMETER_MEMFUN().

Member Data Documentation

boost::shared_ptr<SessionImpl> qpid::client::SessionBase_0_10::impl
protectedinherited

Definition at line 103 of file SessionBase_0_10.h.

Referenced by operator=(), and qpid::client::Session_0_10::operator=().


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

Qpid C++ API Reference
Generated on Thu Mar 31 2016 for Qpid C++ Client API by doxygen 1.8.5