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 #include "qpid/client/ClientImportExport.h"
00032
00033 namespace qpid {
00034 namespace client {
00035 namespace no_keyword {
00036
00040 class AsyncSession_0_10:
00041 public SessionBase_0_10
00042 {
00043 public:
00044
00045 QPID_CLIENT_EXTERN AsyncSession_0_10();
00046 QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10(const SessionBase_0_10& other);
00047 QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10& operator=(const SessionBase_0_10& other);
00048
00049 QPID_CLIENT_EXTERN Completion executionSync(bool sync=false);
00050
00051 QPID_CLIENT_EXTERN Completion executionResult(const SequenceNumber& commandId=SequenceNumber(), const std::string& value=std::string(), bool sync=false);
00052
00053 QPID_CLIENT_EXTERN 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);
00054
00055 QPID_CLIENT_EXTERN 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);
00056
00057 QPID_CLIENT_EXTERN Completion messageAccept(const SequenceSet& transfers=SequenceSet(), bool sync=false);
00058
00059 QPID_CLIENT_EXTERN Completion messageReject(const SequenceSet& transfers=SequenceSet(), uint16_t code=0, const std::string& text=std::string(), bool sync=false);
00060
00061 QPID_CLIENT_EXTERN Completion messageRelease(const SequenceSet& transfers=SequenceSet(), bool setRedelivered=false, bool sync=false);
00062
00063 QPID_CLIENT_EXTERN TypedResult<qpid::framing::MessageAcquireResult> messageAcquire(const SequenceSet& transfers=SequenceSet(), bool sync=false);
00064
00065 QPID_CLIENT_EXTERN TypedResult<qpid::framing::MessageResumeResult> messageResume(const std::string& destination=std::string(), const std::string& resumeId=std::string(), bool sync=false);
00066
00067 QPID_CLIENT_EXTERN 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);
00068
00069 QPID_CLIENT_EXTERN Completion messageCancel(const std::string& destination=std::string(), bool sync=false);
00070
00071 QPID_CLIENT_EXTERN Completion messageSetFlowMode(const std::string& destination=std::string(), uint8_t flowMode=0, bool sync=false);
00072
00073 QPID_CLIENT_EXTERN Completion messageFlow(const std::string& destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=false);
00074
00075 QPID_CLIENT_EXTERN Completion messageFlush(const std::string& destination=std::string(), bool sync=false);
00076
00077 QPID_CLIENT_EXTERN Completion messageStop(const std::string& destination=std::string(), bool sync=false);
00078
00079 QPID_CLIENT_EXTERN Completion txSelect(bool sync=false);
00080
00081 QPID_CLIENT_EXTERN Completion txCommit(bool sync=false);
00082
00083 QPID_CLIENT_EXTERN Completion txRollback(bool sync=false);
00084
00085 QPID_CLIENT_EXTERN Completion dtxSelect(bool sync=false);
00086
00087 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult> dtxStart(const Xid& xid=Xid(), bool join=false, bool resume=false, bool sync=false);
00088
00089 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult> dtxEnd(const Xid& xid=Xid(), bool fail=false, bool suspend=false, bool sync=false);
00090
00091 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult> dtxCommit(const Xid& xid=Xid(), bool onePhase=false, bool sync=false);
00092
00093 QPID_CLIENT_EXTERN Completion dtxForget(const Xid& xid=Xid(), bool sync=false);
00094
00095 QPID_CLIENT_EXTERN TypedResult<qpid::framing::DtxGetTimeoutResult> dtxGetTimeout(const Xid& xid=Xid(), bool sync=false);
00096
00097 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult> dtxPrepare(const Xid& xid=Xid(), bool sync=false);
00098
00099 QPID_CLIENT_EXTERN TypedResult<qpid::framing::DtxRecoverResult> dtxRecover(bool sync=false);
00100
00101 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult> dtxRollback(const Xid& xid=Xid(), bool sync=false);
00102
00103 QPID_CLIENT_EXTERN Completion dtxSetTimeout(const Xid& xid=Xid(), uint32_t timeout=0, bool sync=false);
00104
00105 QPID_CLIENT_EXTERN 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);
00106
00107 QPID_CLIENT_EXTERN Completion exchangeDelete(const std::string& exchange=std::string(), bool ifUnused=false, bool sync=false);
00108
00109 QPID_CLIENT_EXTERN TypedResult<qpid::framing::ExchangeQueryResult> exchangeQuery(const std::string& name=std::string(), bool sync=false);
00110
00111 QPID_CLIENT_EXTERN 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);
00112
00113 QPID_CLIENT_EXTERN Completion exchangeUnbind(const std::string& queue=std::string(), const std::string& exchange=std::string(), const std::string& bindingKey=std::string(), bool sync=false);
00114
00115 QPID_CLIENT_EXTERN 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);
00116
00117 QPID_CLIENT_EXTERN 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);
00118
00119 QPID_CLIENT_EXTERN Completion queueDelete(const std::string& queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=false);
00120
00121 QPID_CLIENT_EXTERN Completion queuePurge(const std::string& queue=std::string(), bool sync=false);
00122
00123 QPID_CLIENT_EXTERN TypedResult<qpid::framing::QueueQueryResult> queueQuery(const std::string& queue=std::string(), bool sync=false);
00124 };
00125
00126 }}}
00127
00128 #endif