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)

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

messageTransfer()

session.messageTransfer(arg::content=message, arg::destination="amq.topic");

messageTransfer() — asynchronous

#include <qpid/client/AsyncSession.h>

 for (int i=0; i<10; i++) {
     message.setData(message_data.str());
     async(session).messageTransfer(arg::content=message,  arg::destination="amq.direct");        
 }

 session.sync();

Exchanges

exchangeBind()

session.exchangeBind(arg::exchange="amq.topic", arg::queue=queue, arg::bindingKey=routing_key);

exchangeUnbind()

session.exchangeUnBind(arg::exchange="amq.topic", arg::queue=queue, arg::bindingKey=routing_key);

exchangeBound()

if (session.exchangeBound(arg::exchange="amq.topic", arg::queue=queue, arg::bindingKey=rk)){...}

if (session.exchangeBound(arg::exchange="amq.topic", arg::queue=queue)){...}

exchangeDeclare()

session.exchangeDeclare(arg::exchange="my.topic", arg::type="topic");

session.exchangeDeclare(arg::exchange="xml", arg::type="xml");

exchangeDelete()

session.exchangeDeclare(arg::exchange="my.topic");

session.exchangeDeclare(arg::exchange="xml", arg::ifUnused=true);

exchangeQuery()

ExchangeQueryResult eqr = session.exchangeQuery(arg::exchange="my.topic");

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

queueDeclare()

session.queueDeclare(arg::queue="message_queue");

queueDelete()

session.queueDelete(arg::queue="message_queue");

queuePurge()

session.queuePurge(arg::queue="message_queue");

queueQuery()

QueueQueryResult qqr = session.queueQuery(arg::queue="message_queue");

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

messageAccept() — acknowledges messages

SequenceSet tobeAccepted; 
 toAccepted.add(msg.getId()); 
 session.messageAccept(toBeAccepted);

messageAcquire()

SequenceSet tobeAcquired;
 toBeAcquired.add(msg.getId()); 
 session.messageAcquire(toBeAcquired);

messageReject()

SequenceSet tobeRejected; 
 toRejected.add(msg.getId()); 
 session.messageReject(toBeRejected);

messageRelease()

SequenceSet tobeReleased; 
 toReleased.add(msg.getId()); 
 session.messageRelease(toBeReleased);

Transactions

txSelect()
```
session.txSelect();
```
txCommit()
```
session.txSelect();
```
txRollback()
```
session.txRollback();
```

Definition at line 189 of file AsyncSession_0_10.h.

Constructor & Destructor Documentation

qpid::client::AsyncSession_0_10::AsyncSession_0_10 ( ) [inline]

Reimplemented from qpid::client::no_keyword::AsyncSession_0_10.

Definition at line 555 of file AsyncSession_0_10.h.

qpid::client::AsyncSession_0_10::AsyncSession_0_10 ( const SessionBase_0_10 & other ) [inline]

Reimplemented from qpid::client::no_keyword::AsyncSession_0_10.

Definition at line 556 of file AsyncSession_0_10.h.

Member Function Documentation

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		executionSync	,
		0	,
		1	,
		ExecutionSyncParameters
	)		`[inline]`

Definition at line 276 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::executionSync(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		executionResult	,
		0	,
		3	,
		ExecutionResultParameters
	)		`[inline]`

Definition at line 281 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::executionResult(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		executionException	,
		0	,
		8	,
		ExecutionExceptionParameters
	)		`[inline]`

Definition at line 288 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::executionException(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageTransfer	,
		0	,
		5	,
		MessageTransferParameters
	)		`[inline]`

Definition at line 300 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageTransfer(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageAccept	,
		0	,
		2	,
		MessageAcceptParameters
	)		`[inline]`

Definition at line 309 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageAccept(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageReject	,
		0	,
		4	,
		MessageRejectParameters
	)		`[inline]`

Definition at line 315 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageReject(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageRelease	,
		0	,
		3	,
		MessageReleaseParameters
	)		`[inline]`

Definition at line 323 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageRelease(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::MessageAcquireResult >	,
		messageAcquire	,
		0	,
		2	,
		MessageAcquireParameters
	)		`[inline]`

Definition at line 330 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageAcquire(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::MessageResumeResult >	,
		messageResume	,
		0	,
		3	,
		MessageResumeParameters
	)		`[inline]`

Definition at line 336 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageResume(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageSubscribe	,
		0	,
		9	,
		MessageSubscribeParameters
	)		`[inline]`

Definition at line 343 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageSubscribe(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageCancel	,
		0	,
		2	,
		MessageCancelParameters
	)		`[inline]`

Definition at line 356 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageCancel(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageSetFlowMode	,
		0	,
		3	,
		MessageSetFlowModeParameters
	)		`[inline]`

Definition at line 362 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageSetFlowMode(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageFlow	,
		0	,
		4	,
		MessageFlowParameters
	)		`[inline]`

Definition at line 369 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageFlow(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageFlush	,
		0	,
		2	,
		MessageFlushParameters
	)		`[inline]`

Definition at line 377 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageFlush(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		messageStop	,
		0	,
		2	,
		MessageStopParameters
	)		`[inline]`

Definition at line 383 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::messageStop(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		txSelect	,
		0	,
		1	,
		TxSelectParameters
	)		`[inline]`

Definition at line 389 of file AsyncSession_0_10.h.

References qpid::client::sync(), and qpid::client::no_keyword::AsyncSession_0_10::txSelect().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		txCommit	,
		0	,
		1	,
		TxCommitParameters
	)		`[inline]`

Definition at line 394 of file AsyncSession_0_10.h.

References qpid::client::sync(), and qpid::client::no_keyword::AsyncSession_0_10::txCommit().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		txRollback	,
		0	,
		1	,
		TxRollbackParameters
	)		`[inline]`

Definition at line 399 of file AsyncSession_0_10.h.

References qpid::client::sync(), and qpid::client::no_keyword::AsyncSession_0_10::txRollback().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		dtxSelect	,
		0	,
		1	,
		DtxSelectParameters
	)		`[inline]`

Definition at line 404 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxSelect(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::XaResult >	,
		dtxStart	,
		0	,
		4	,
		DtxStartParameters
	)		`[inline]`

Definition at line 409 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxStart(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::XaResult >	,
		dtxEnd	,
		0	,
		4	,
		DtxEndParameters
	)		`[inline]`

Definition at line 417 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxEnd(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::XaResult >	,
		dtxCommit	,
		0	,
		3	,
		DtxCommitParameters
	)		`[inline]`

Definition at line 425 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxCommit(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		dtxForget	,
		0	,
		2	,
		DtxForgetParameters
	)		`[inline]`

Definition at line 432 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxForget(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::DtxGetTimeoutResult >	,
		dtxGetTimeout	,
		0	,
		2	,
		DtxGetTimeoutParameters
	)		`[inline]`

Definition at line 438 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxGetTimeout(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::XaResult >	,
		dtxPrepare	,
		0	,
		2	,
		DtxPrepareParameters
	)		`[inline]`

Definition at line 444 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxPrepare(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::DtxRecoverResult >	,
		dtxRecover	,
		0	,
		1	,
		DtxRecoverParameters
	)		`[inline]`

Definition at line 450 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxRecover(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::XaResult >	,
		dtxRollback	,
		0	,
		2	,
		DtxRollbackParameters
	)		`[inline]`

Definition at line 455 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxRollback(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		dtxSetTimeout	,
		0	,
		3	,
		DtxSetTimeoutParameters
	)		`[inline]`

Definition at line 461 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::dtxSetTimeout(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		exchangeDeclare	,
		0	,
		8	,
		ExchangeDeclareParameters
	)		`[inline]`

Definition at line 468 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::exchangeDeclare(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		exchangeDelete	,
		0	,
		3	,
		ExchangeDeleteParameters
	)		`[inline]`

Definition at line 480 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::exchangeDelete(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::ExchangeQueryResult >	,
		exchangeQuery	,
		0	,
		2	,
		ExchangeQueryParameters
	)		`[inline]`

Definition at line 487 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::exchangeQuery(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		exchangeBind	,
		0	,
		5	,
		ExchangeBindParameters
	)		`[inline]`

Definition at line 493 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::exchangeBind(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		exchangeUnbind	,
		0	,
		4	,
		ExchangeUnbindParameters
	)		`[inline]`

Definition at line 502 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::exchangeUnbind(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::ExchangeBoundResult >	,
		exchangeBound	,
		0	,
		5	,
		ExchangeBoundParameters
	)		`[inline]`

Definition at line 510 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::exchangeBound(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		queueDeclare	,
		0	,
		8	,
		QueueDeclareParameters
	)		`[inline]`

Definition at line 519 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::queueDeclare(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		queueDelete	,
		0	,
		4	,
		QueueDeleteParameters
	)		`[inline]`

Definition at line 531 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::queueDelete(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	Completion	,
		queuePurge	,
		0	,
		2	,
		QueuePurgeParameters
	)		`[inline]`

Definition at line 539 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::queuePurge(), and qpid::client::sync().

qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN	(	TypedResult< qpid::framing::QueueQueryResult >	,
		queueQuery	,
		0	,
		2	,
		QueueQueryParameters
	)		`[inline]`

Definition at line 545 of file AsyncSession_0_10.h.

References qpid::client::no_keyword::AsyncSession_0_10::queueQuery(), and qpid::client::sync().

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().

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]

Reimplemented from qpid::client::no_keyword::AsyncSession_0_10.

Definition at line 559 of file AsyncSession_0_10.h.

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]`