00001 #ifndef QPID_CLIENT_NO_KEYWORD_SESSION_0_10_H
00002 #define QPID_CLIENT_NO_KEYWORD_SESSION_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.h"
00031
00032 namespace qpid {
00033 namespace client {
00034
00035 using std::string;
00036 using framing::Content;
00037 using framing::FieldTable;
00038 using framing::MethodContent;
00039 using framing::SequenceNumber;
00040 using framing::SequenceSet;
00041 using framing::Uuid;
00042 using framing::Xid;
00043
00044
00045 namespace no_keyword {
00046
00056 class Session_0_10:
00057 public SessionBase
00058 {
00059 public:
00060 Session_0_10() {}
00061 Session_0_10(shared_ptr<SessionImpl> core) : SessionBase(core) {}
00062
00069 Completion executionSync();
00070
00081 Completion executionResult(const SequenceNumber& commandId=SequenceNumber(), const string& value=string());
00082
00117 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());
00118
00150 Completion messageTransfer(const string& destination=string(), uint8_t acceptMode=0, uint8_t acquireMode=0, const MethodContent& content=DefaultContent(std::string()));
00151
00164 Completion messageAccept(const SequenceSet& transfers=SequenceSet());
00165
00190 Completion messageReject(const SequenceSet& transfers=SequenceSet(), uint16_t code=0, const string& text=string());
00191
00213 Completion messageRelease(const SequenceSet& transfers=SequenceSet(), bool setRedelivered=false);
00214
00227 TypedResult<qpid::framing::MessageAcquireResult> messageAcquire(const SequenceSet& transfers=SequenceSet());
00228
00248 TypedResult<qpid::framing::MessageResumeResult> messageResume(const string& destination=string(), const string& resumeId=string());
00249
00286 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());
00287
00299 Completion messageCancel(const string& destination=string());
00300
00333 Completion messageSetFlowMode(const string& destination=string(), uint8_t flowMode=0);
00334
00358 Completion messageFlow(const string& destination=string(), uint8_t unit=0, uint32_t value=0);
00359
00370 Completion messageFlush(const string& destination=string());
00371
00382 Completion messageStop(const string& destination=string());
00383
00391 Completion txSelect();
00392
00400 Completion txCommit();
00401
00410 Completion txRollback();
00411
00419 Completion dtxSelect();
00420
00444 TypedResult<qpid::framing::XaResult> dtxStart(const Xid& xid=Xid(), bool join=false, bool resume=false);
00445
00469 TypedResult<qpid::framing::XaResult> dtxEnd(const Xid& xid=Xid(), bool fail=false, bool suspend=false);
00470
00489 TypedResult<qpid::framing::XaResult> dtxCommit(const Xid& xid=Xid(), bool onePhase=false);
00490
00502 Completion dtxForget(const Xid& xid=Xid());
00503
00517 TypedResult<qpid::framing::DtxGetTimeoutResult> dtxGetTimeout(const Xid& xid=Xid());
00518
00530 TypedResult<qpid::framing::XaResult> dtxPrepare(const Xid& xid=Xid());
00531
00539 TypedResult<qpid::framing::DtxRecoverResult> dtxRecover();
00540
00553 TypedResult<qpid::framing::XaResult> dtxRollback(const Xid& xid=Xid());
00554
00571 Completion dtxSetTimeout(const Xid& xid=Xid(), uint32_t timeout=0);
00572
00625 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());
00626
00643 Completion exchangeDelete(const string& exchange=string(), bool ifUnused=false);
00644
00657 TypedResult<qpid::framing::ExchangeQueryResult> exchangeQuery(const string& name=string());
00658
00682 Completion exchangeBind(const string& queue=string(), const string& exchange=string(), const string& bindingKey=string(), const FieldTable& arguments=FieldTable());
00683
00705 Completion exchangeUnbind(const string& queue=string(), const string& exchange=string(), const string& bindingKey=string());
00706
00736 TypedResult<qpid::framing::ExchangeBoundResult> exchangeBound(const string& exchange=string(), const string& queue=string(), const string& bindingKey=string(), const FieldTable& arguments=FieldTable());
00737
00795 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());
00796
00820 Completion queueDelete(const string& queue=string(), bool ifUnused=false, bool ifEmpty=false);
00821
00834 Completion queuePurge(const string& queue=string());
00835
00844 TypedResult<qpid::framing::QueueQueryResult> queueQuery(const string& queue=string());
00845 };
00846
00847 }
00848
00849
00850 }}
00851
00852 #endif