00001 #ifndef QPID_CLIENT_NO_KEYWORD_ASYNCSESSION_0_10_H
00002 #define QPID_CLIENT_NO_KEYWORD_ASYNCSESSION_0_10_H
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00028
00029
00030 #include "qpid/client/SessionBase_0_10.h"
00031
00032 namespace qpid {
00033 namespace client {
00034 namespace no_keyword {
00035
00045 class AsyncSession_0_10:
00046 public SessionBase_0_10
00047 {
00048 public:
00049
00050 AsyncSession_0_10();
00051 AsyncSession_0_10(const SessionBase_0_10& other);
00052 AsyncSession_0_10& operator=(const SessionBase_0_10& other);
00053
00060 Completion executionSync();
00061
00072 Completion executionResult(const SequenceNumber& commandId=SequenceNumber(), const string& value=string());
00073
00108 Completion executionException(uint16_t errorCode=0, const SequenceNumber& commandId=SequenceNumber(), uint8_t classCode=0, uint8_t commandCode=0, uint8_t fieldIndex=0, const string& description=string(), const FieldTable& errorInfo=FieldTable());
00109
00141 Completion messageTransfer(const string& destination=string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const MethodContent& content=DefaultContent(std::string()));
00142
00155 Completion messageAccept(const SequenceSet& transfers=SequenceSet());
00156
00181 Completion messageReject(const SequenceSet& transfers=SequenceSet(), uint16_t code=0, const string& text=string());
00182
00204 Completion messageRelease(const SequenceSet& transfers=SequenceSet(), bool setRedelivered=false);
00205
00218 TypedResult<qpid::framing::MessageAcquireResult> messageAcquire(const SequenceSet& transfers=SequenceSet());
00219
00239 TypedResult<qpid::framing::MessageResumeResult> messageResume(const string& destination=string(), const string& resumeId=string());
00240
00277 Completion messageSubscribe(const string& queue=string(), const string& destination=string(), uint8_t acceptMode=0, uint8_t acquireMode=0, bool exclusive=false, const string& resumeId=string(), uint64_t resumeTtl=0, const FieldTable& arguments=FieldTable());
00278
00290 Completion messageCancel(const string& destination=string());
00291
00324 Completion messageSetFlowMode(const string& destination=string(), uint8_t flowMode=0);
00325
00349 Completion messageFlow(const string& destination=string(), uint8_t unit=0, uint32_t value=0);
00350
00361 Completion messageFlush(const string& destination=string());
00362
00373 Completion messageStop(const string& destination=string());
00374
00382 Completion txSelect();
00383
00391 Completion txCommit();
00392
00401 Completion txRollback();
00402
00410 Completion dtxSelect();
00411
00435 TypedResult<qpid::framing::XaResult> dtxStart(const Xid& xid=Xid(), bool join=false, bool resume=false);
00436
00460 TypedResult<qpid::framing::XaResult> dtxEnd(const Xid& xid=Xid(), bool fail=false, bool suspend=false);
00461
00480 TypedResult<qpid::framing::XaResult> dtxCommit(const Xid& xid=Xid(), bool onePhase=false);
00481
00493 Completion dtxForget(const Xid& xid=Xid());
00494
00508 TypedResult<qpid::framing::DtxGetTimeoutResult> dtxGetTimeout(const Xid& xid=Xid());
00509
00521 TypedResult<qpid::framing::XaResult> dtxPrepare(const Xid& xid=Xid());
00522
00530 TypedResult<qpid::framing::DtxRecoverResult> dtxRecover();
00531
00544 TypedResult<qpid::framing::XaResult> dtxRollback(const Xid& xid=Xid());
00545
00562 Completion dtxSetTimeout(const Xid& xid=Xid(), uint32_t timeout=0);
00563
00616 Completion exchangeDeclare(const string& exchange=string(), const string& type=string(), const string& alternateExchange=string(), bool passive=false, bool durable=false, bool autoDelete=false, const FieldTable& arguments=FieldTable());
00617
00634 Completion exchangeDelete(const string& exchange=string(), bool ifUnused=false);
00635
00648 TypedResult<qpid::framing::ExchangeQueryResult> exchangeQuery(const string& name=string());
00649
00673 Completion exchangeBind(const string& queue=string(), const string& exchange=string(), const string& bindingKey=string(), const FieldTable& arguments=FieldTable());
00674
00696 Completion exchangeUnbind(const string& queue=string(), const string& exchange=string(), const string& bindingKey=string());
00697
00727 TypedResult<qpid::framing::ExchangeBoundResult> exchangeBound(const string& exchange=string(), const string& queue=string(), const string& bindingKey=string(), const FieldTable& arguments=FieldTable());
00728
00786 Completion queueDeclare(const string& queue=string(), const string& alternateExchange=string(), bool passive=false, bool durable=false, bool exclusive=false, bool autoDelete=false, const FieldTable& arguments=FieldTable());
00787
00811 Completion queueDelete(const string& queue=string(), bool ifUnused=false, bool ifEmpty=false);
00812
00825 Completion queuePurge(const string& queue=string());
00826
00835 TypedResult<qpid::framing::QueueQueryResult> queueQuery(const string& queue=string());
00836 };
00837
00838 }}}
00839
00840 #endif