00001 #ifndef QPID_CLIENT_NO_KEYWORD_SESSION_99_0_H
00002 #define QPID_CLIENT_NO_KEYWORD_SESSION_99_0_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::SequenceNumberSet;
00040 using framing::Uuid;
00041
00042
00043 namespace no_keyword {
00044
00052 class Session_99_0:
00053 public SessionBase
00054 {
00055 public:
00056 Session_99_0() {}
00057 Session_99_0(shared_ptr<SessionCore> core) : SessionBase(core) {}
00058
00105 Response accessRequest(const string& realm=string(), bool exclusive=false, bool passive=false, bool active=false, bool write=false, bool read=false);
00106
00161 Completion exchangeDeclare(uint16_t ticket=0, 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());
00162
00181 Completion exchangeDelete(uint16_t ticket=0, const string& exchange=string(), bool ifUnused=false);
00182
00197 TypedResult<qpid::framing::ExchangeQueryResult> exchangeQuery(uint16_t ticket=0, const string& name=string());
00198
00264 Completion queueDeclare(uint16_t ticket=0, const string& queue=string(), const string& alternateExchange=string(), bool passive=false, bool durable=false, bool exclusive=false, bool autoDelete=false, const FieldTable& arguments=FieldTable());
00265
00301 Completion queueBind(uint16_t ticket=0, const string& queue=string(), const string& exchange=string(), const string& routingKey=string(), const FieldTable& arguments=FieldTable());
00302
00331 Completion queueUnbind(uint16_t ticket=0, const string& queue=string(), const string& exchange=string(), const string& routingKey=string(), const FieldTable& arguments=FieldTable());
00332
00348 Completion queuePurge(uint16_t ticket=0, const string& queue=string());
00349
00377 Completion queueDelete(uint16_t ticket=0, const string& queue=string(), bool ifUnused=false, bool ifEmpty=false);
00378
00387 TypedResult<qpid::framing::QueueQueryResult> queueQuery(const string& queue=string());
00388
00424 Completion basicQos(uint32_t prefetchSize=0, uint16_t prefetchCount=0, bool global=false);
00425
00471 Response basicConsume(uint16_t ticket=0, const string& queue=string(), const string& consumerTag=string(), bool noLocal=false, bool noAck=false, bool exclusive=false, bool nowait=false, const FieldTable& arguments=FieldTable());
00472
00484 Completion basicCancel(const string& consumerTag=string());
00485
00527 Completion basicPublish(uint16_t ticket=0, const string& exchange=string(), const string& routingKey=string(), bool rejectUnroutable=false, bool immediate=false, const MethodContent& content=DefaultContent(std::string()));
00528
00547 Response basicGet(uint16_t ticket=0, const string& queue=string(), bool noAck=false);
00548
00567 Completion basicAck(uint64_t deliveryTag=0, bool multiple=false);
00568
00585 Completion basicReject(uint64_t deliveryTag=0, bool requeue=false);
00586
00602 Completion basicRecover(bool requeue=false);
00603
00637 Response fileQos(uint32_t prefetchSize=0, uint16_t prefetchCount=0, bool global=false);
00638
00684 Response fileConsume(uint16_t ticket=0, const string& queue=string(), const string& consumerTag=string(), bool noLocal=false, bool noAck=false, bool exclusive=false, bool nowait=false, const FieldTable& filter=FieldTable());
00685
00695 Completion fileCancel(const string& consumerTag=string());
00696
00723 Response fileOpen(const string& identifier=string(), uint64_t contentSize=0);
00724
00738 Response fileOpenOk(uint64_t stagedSize=0);
00739
00750 Completion fileStage(const MethodContent& content=DefaultContent(std::string()));
00751
00797 Completion filePublish(uint16_t ticket=0, const string& exchange=string(), const string& routingKey=string(), bool mandatory=false, bool immediate=false, const string& identifier=string());
00798
00817 Completion fileAck(uint64_t deliveryTag=0, bool multiple=false);
00818
00835 Completion fileReject(uint64_t deliveryTag=0, bool requeue=false);
00836
00875 Response streamQos(uint32_t prefetchSize=0, uint16_t prefetchCount=0, uint32_t consumeRate=0, bool global=false);
00876
00920 Response streamConsume(uint16_t ticket=0, const string& queue=string(), const string& consumerTag=string(), bool noLocal=false, bool exclusive=false, bool nowait=false, const FieldTable& filter=FieldTable());
00921
00932 Completion streamCancel(const string& consumerTag=string());
00933
00975 Completion streamPublish(uint16_t ticket=0, const string& exchange=string(), const string& routingKey=string(), bool mandatory=false, bool immediate=false, const MethodContent& content=DefaultContent(std::string()));
00976
00984 Completion txSelect();
00985
00993 Completion txCommit();
00994
01002 Completion txRollback();
01003
01011 Completion dtxDemarcationSelect();
01012
01041 TypedResult<qpid::framing::DtxDemarcationStartResult> dtxDemarcationStart(uint16_t ticket=0, const string& xid=string(), bool join=false, bool resume=false);
01042
01071 TypedResult<qpid::framing::DtxDemarcationEndResult> dtxDemarcationEnd(uint16_t ticket=0, const string& xid=string(), bool fail=false, bool suspend=false);
01072
01095 TypedResult<qpid::framing::DtxCoordinationCommitResult> dtxCoordinationCommit(uint16_t ticket=0, const string& xid=string(), bool onePhase=false);
01096
01113 Completion dtxCoordinationForget(uint16_t ticket=0, const string& xid=string());
01114
01128 TypedResult<qpid::framing::DtxCoordinationGetTimeoutResult> dtxCoordinationGetTimeout(const string& xid=string());
01129
01146 TypedResult<qpid::framing::DtxCoordinationPrepareResult> dtxCoordinationPrepare(uint16_t ticket=0, const string& xid=string());
01147
01170 TypedResult<qpid::framing::DtxCoordinationRecoverResult> dtxCoordinationRecover(uint16_t ticket=0, bool startscan=false, bool endscan=false);
01171
01189 TypedResult<qpid::framing::DtxCoordinationRollbackResult> dtxCoordinationRollback(uint16_t ticket=0, const string& xid=string());
01190
01212 Completion dtxCoordinationSetTimeout(uint16_t ticket=0, const string& xid=string(), uint32_t timeout=0);
01213
01229 Completion tunnelRequest(const FieldTable& metaData=FieldTable(), const MethodContent& content=DefaultContent(std::string()));
01230
01260 Completion messageTransfer(uint16_t ticket=0, const string& destination=string(), uint8_t confirmMode=0, uint8_t acquireMode=0, const MethodContent& content=DefaultContent(std::string()));
01261
01276 Completion messageReject(const SequenceNumberSet& transfers=SequenceNumberSet(), uint16_t code=0, const string& text=string());
01277
01294 Completion messageAcquire(const SequenceNumberSet& transfers=SequenceNumberSet(), uint8_t mode=0);
01295
01306 Completion messageRelease(const SequenceNumberSet& transfers=SequenceNumberSet());
01307
01356 Completion messageSubscribe(uint16_t ticket=0, const string& queue=string(), const string& destination=string(), bool noLocal=false, uint8_t confirmMode=0, uint8_t acquireMode=0, bool exclusive=false, const FieldTable& filter=FieldTable());
01357
01369 Completion messageCancel(const string& destination=string());
01370
01395 Response messageGet(uint16_t ticket=0, const string& queue=string(), const string& destination=string(), bool noAck=false);
01396
01412 Completion messageRecover(bool requeue=false);
01413
01430 Completion messageOpen(const string& reference=string());
01431
01440 Completion messageClose(const string& reference=string());
01441
01450 Completion messageAppend(const string& reference=string(), const string& bytes=string());
01451
01472 Completion messageCheckpoint(const string& reference=string(), const string& identifier=string());
01473
01486 Response messageResume(const string& reference=string(), const string& identifier=string());
01487
01522 Completion messageQos(uint32_t prefetchSize=0, uint16_t prefetchCount=0, bool global=false);
01523
01553 Completion messageFlowMode(const string& destination=string(), uint8_t mode=0);
01554
01582 Completion messageFlow(const string& destination=string(), uint8_t unit=0, uint32_t value=0);
01583
01593 Completion messageFlush(const string& destination=string());
01594
01606 Completion messageStop(const string& destination=string());
01607
01615 Completion messageEmpty();
01616
01628 Completion messageOffset(uint64_t value=0);
01629
01661 TypedResult<qpid::framing::BindingQueryResult> bindingQuery(uint16_t ticket=0, const string& exchange=string(), const string& queue=string(), const string& routingKey=string(), const FieldTable& arguments=FieldTable());
01662 };
01663
01664 }
01665
01666
01667 }}
01668
01669 #endif