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_0_10.h"
00031
00032 namespace qpid {
00033 namespace client {
00034 namespace no_keyword {
00035
00045 class Session_0_10:
00046 public SessionBase_0_10
00047 {
00048 public:
00049
00050 Session_0_10();
00051 Session_0_10(const SessionBase_0_10& other);
00052 Session_0_10& operator=(const SessionBase_0_10& other);
00053
00060 void executionSync();
00061
00072 void executionResult(const SequenceNumber& commandId=SequenceNumber(), const string& value=string());
00073
00108 void 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 void messageTransfer(const string& destination=string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const MethodContent& content=DefaultContent(std::string()));
00142
00155 void messageAccept(const SequenceSet& transfers=SequenceSet());
00156
00181 void messageReject(const SequenceSet& transfers=SequenceSet(), uint16_t code=0, const string& text=string());
00182
00204 void messageRelease(const SequenceSet& transfers=SequenceSet(), bool setRedelivered=false);
00205
00218 qpid::framing::MessageAcquireResult messageAcquire(const SequenceSet& transfers=SequenceSet());
00219
00239 qpid::framing::MessageResumeResult messageResume(const string& destination=string(), const string& resumeId=string());
00240
00277 void 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 void messageCancel(const string& destination=string());
00291
00324 void messageSetFlowMode(const string& destination=string(), uint8_t flowMode=0);
00325
00349 void messageFlow(const string& destination=string(), uint8_t unit=0, uint32_t value=0);
00350
00361 void messageFlush(const string& destination=string());
00362
00373 void messageStop(const string& destination=string());
00374
00382 void txSelect();
00383
00391 void txCommit();
00392
00401 void txRollback();
00402
00410 void dtxSelect();
00411
00435 qpid::framing::XaResult dtxStart(const Xid& xid=Xid(), bool join=false, bool resume=false);
00436
00460 qpid::framing::XaResult dtxEnd(const Xid& xid=Xid(), bool fail=false, bool suspend=false);
00461
00480 qpid::framing::XaResult dtxCommit(const Xid& xid=Xid(), bool onePhase=false);
00481
00493 void dtxForget(const Xid& xid=Xid());
00494
00508 qpid::framing::DtxGetTimeoutResult dtxGetTimeout(const Xid& xid=Xid());
00509
00521 qpid::framing::XaResult dtxPrepare(const Xid& xid=Xid());
00522
00530 qpid::framing::DtxRecoverResult dtxRecover();
00531
00544 qpid::framing::XaResult dtxRollback(const Xid& xid=Xid());
00545
00562 void dtxSetTimeout(const Xid& xid=Xid(), uint32_t timeout=0);
00563
00616 void 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 void exchangeDelete(const string& exchange=string(), bool ifUnused=false);
00635
00648 qpid::framing::ExchangeQueryResult exchangeQuery(const string& name=string());
00649
00673 void exchangeBind(const string& queue=string(), const string& exchange=string(), const string& bindingKey=string(), const FieldTable& arguments=FieldTable());
00674
00696 void exchangeUnbind(const string& queue=string(), const string& exchange=string(), const string& bindingKey=string());
00697
00727 qpid::framing::ExchangeBoundResult exchangeBound(const string& exchange=string(), const string& queue=string(), const string& bindingKey=string(), const FieldTable& arguments=FieldTable());
00728
00786 void 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 void queueDelete(const string& queue=string(), bool ifUnused=false, bool ifEmpty=false);
00812
00825 void queuePurge(const string& queue=string());
00826
00835 qpid::framing::QueueQueryResult queueQuery(const string& queue=string());
00836 };
00837
00838 }}}
00839
00840 #endif