Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET Apache Qpid Documentation
Session_0_10.h
Go to the documentation of this file.
1 #ifndef QPID_CLIENT_NO_KEYWORD_SESSION_0_10_H
2 #define QPID_CLIENT_NO_KEYWORD_SESSION_0_10_H
3 /*
4  *
5  * Licensed to the Apache Software Foundation (ASF) under one
6  * or more contributor license agreements. See the NOTICE file
7  * distributed with this work for additional information
8  * regarding copyright ownership. The ASF licenses this file
9  * to you under the Apache License, Version 2.0 (the
10  * "License"); you may not use this file except in compliance
11  * with the License. You may obtain a copy of the License at
12  *
13  * http://www.apache.org/licenses/LICENSE-2.0
14  *
15  * Unless required by applicable law or agreed to in writing,
16  * software distributed under the License is distributed on an
17  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
18  * KIND, either express or implied. See the License for the
19  * specific language governing permissions and limitations
20  * under the License.
21  *
22  */
23 
28 
29 
30 #include "qpid/client/SessionBase_0_10.h"
31 #include "qpid/client/ClientImportExport.h"
32 
33 namespace qpid {
34 namespace client {
35 namespace no_keyword {
36 
41  public SessionBase_0_10
42 {
43  public:
44 
45  QPID_CLIENT_EXTERN Session_0_10();
46  QPID_CLIENT_INLINE_EXTERN Session_0_10(const SessionBase_0_10& other);
47  QPID_CLIENT_INLINE_EXTERN Session_0_10& operator=(const SessionBase_0_10& other);
48 
49  QPID_CLIENT_EXTERN void executionSync(bool sync=true);
50 
51  QPID_CLIENT_EXTERN void executionResult(const SequenceNumber& commandId=SequenceNumber(), const std::string& value=std::string(), bool sync=true);
52 
53  QPID_CLIENT_EXTERN void 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=true);
54 
55  QPID_CLIENT_EXTERN void messageTransfer(const std::string& destination=std::string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const Message& content=Message(std::string()), bool sync=true);
56 
57  QPID_CLIENT_EXTERN void messageAccept(const SequenceSet& transfers=SequenceSet(), bool sync=true);
58 
59  QPID_CLIENT_EXTERN void messageReject(const SequenceSet& transfers=SequenceSet(), uint16_t code=0, const std::string& text=std::string(), bool sync=true);
60 
61  QPID_CLIENT_EXTERN void messageRelease(const SequenceSet& transfers=SequenceSet(), bool setRedelivered=false, bool sync=true);
62 
63  QPID_CLIENT_EXTERN qpid::framing::MessageAcquireResult messageAcquire(const SequenceSet& transfers=SequenceSet(), bool sync=true);
64 
65  QPID_CLIENT_EXTERN qpid::framing::MessageResumeResult messageResume(const std::string& destination=std::string(), const std::string& resumeId=std::string(), bool sync=true);
66 
67  QPID_CLIENT_EXTERN void 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=true);
68 
69  QPID_CLIENT_EXTERN void messageCancel(const std::string& destination=std::string(), bool sync=true);
70 
71  QPID_CLIENT_EXTERN void messageSetFlowMode(const std::string& destination=std::string(), uint8_t flowMode=0, bool sync=true);
72 
73  QPID_CLIENT_EXTERN void messageFlow(const std::string& destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=true);
74 
75  QPID_CLIENT_EXTERN void messageFlush(const std::string& destination=std::string(), bool sync=true);
76 
77  QPID_CLIENT_EXTERN void messageStop(const std::string& destination=std::string(), bool sync=true);
78 
79  QPID_CLIENT_EXTERN void txSelect(bool sync=true);
80 
81  QPID_CLIENT_EXTERN void txCommit(bool sync=true);
82 
83  QPID_CLIENT_EXTERN void txRollback(bool sync=true);
84 
85  QPID_CLIENT_EXTERN void dtxSelect(bool sync=true);
86 
87  QPID_CLIENT_EXTERN qpid::framing::XaResult dtxStart(const Xid& xid=Xid(), bool join=false, bool resume=false, bool sync=true);
88 
89  QPID_CLIENT_EXTERN qpid::framing::XaResult dtxEnd(const Xid& xid=Xid(), bool fail=false, bool suspend=false, bool sync=true);
90 
91  QPID_CLIENT_EXTERN qpid::framing::XaResult dtxCommit(const Xid& xid=Xid(), bool onePhase=false, bool sync=true);
92 
93  QPID_CLIENT_EXTERN void dtxForget(const Xid& xid=Xid(), bool sync=true);
94 
95  QPID_CLIENT_EXTERN qpid::framing::DtxGetTimeoutResult dtxGetTimeout(const Xid& xid=Xid(), bool sync=true);
96 
97  QPID_CLIENT_EXTERN qpid::framing::XaResult dtxPrepare(const Xid& xid=Xid(), bool sync=true);
98 
99  QPID_CLIENT_EXTERN qpid::framing::DtxRecoverResult dtxRecover(bool sync=true);
100 
101  QPID_CLIENT_EXTERN qpid::framing::XaResult dtxRollback(const Xid& xid=Xid(), bool sync=true);
102 
103  QPID_CLIENT_EXTERN void dtxSetTimeout(const Xid& xid=Xid(), uint32_t timeout=0, bool sync=true);
104 
105  QPID_CLIENT_EXTERN void 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=true);
106 
107  QPID_CLIENT_EXTERN void exchangeDelete(const std::string& exchange=std::string(), bool ifUnused=false, bool sync=true);
108 
109  QPID_CLIENT_EXTERN qpid::framing::ExchangeQueryResult exchangeQuery(const std::string& name=std::string(), bool sync=true);
110 
111  QPID_CLIENT_EXTERN void 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=true);
112 
113  QPID_CLIENT_EXTERN void exchangeUnbind(const std::string& queue=std::string(), const std::string& exchange=std::string(), const std::string& bindingKey=std::string(), bool sync=true);
114 
115  QPID_CLIENT_EXTERN 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=true);
116 
117  QPID_CLIENT_EXTERN void 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=true);
118 
119  QPID_CLIENT_EXTERN void queueDelete(const std::string& queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=true);
120 
121  QPID_CLIENT_EXTERN void queuePurge(const std::string& queue=std::string(), bool sync=true);
122 
123  QPID_CLIENT_EXTERN qpid::framing::QueueQueryResult queueQuery(const std::string& queue=std::string(), bool sync=true);
124 };
125 
126 }}} // namespace qpid::client::no_keyword
127 
128 #endif
uint64_t
unsigned __int64 uint64_t
Definition: IntegerTypes.h:36
qpid::client::no_keyword::Session_0_10::messageFlow
void messageFlow(const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=true)
qpid::client::no_keyword::Session_0_10::exchangeBound
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=true)
qpid::framing::MessageAcquireResult
Definition: MessageAcquireResult.h:39
qpid::client::no_keyword::Session_0_10::messageSubscribe
void 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=true)
qpid::client::no_keyword::Session_0_10::executionResult
void executionResult(const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=true)
qpid::framing::ExchangeBoundResult
Definition: ExchangeBoundResult.h:39
qpid::framing::QueueQueryResult
Definition: QueueQueryResult.h:39
qpid::client::no_keyword::Session_0_10::messageCancel
void messageCancel(const std::string &destination=std::string(), bool sync=true)
qpid::client::no_keyword::Session_0_10::executionException
void 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=true)
qpid::client::no_keyword::Session_0_10
AMQP 0-10 synchronous session API.
Definition: Session_0_10.h:40
qpid::client::no_keyword::Session_0_10::Session_0_10
Session_0_10()
qpid::client::no_keyword::Session_0_10::messageRelease
void messageRelease(const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=true)
qpid::client::no_keyword::Session_0_10::txRollback
void txRollback(bool sync=true)
qpid::client::no_keyword::Session_0_10::queuePurge
void queuePurge(const std::string &queue=std::string(), bool sync=true)
qpid::client::no_keyword::Session_0_10::exchangeUnbind
void exchangeUnbind(const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=true)
qpid
This file was automatically generated from the AMQP specification.
Definition: arg.h:33
qpid::client::no_keyword::Session_0_10::dtxSelect
void dtxSelect(bool sync=true)
qpid::client::no_keyword::Session_0_10::dtxRecover
qpid::framing::DtxRecoverResult dtxRecover(bool sync=true)
uint16_t
unsigned short uint16_t
Definition: IntegerTypes.h:32
qpid::client::no_keyword::Session_0_10::exchangeQuery
qpid::framing::ExchangeQueryResult exchangeQuery(const std::string &name=std::string(), bool sync=true)
qpid::client::no_keyword::Session_0_10::dtxCommit
qpid::framing::XaResult dtxCommit(const Xid &xid=Xid(), bool onePhase=false, bool sync=true)
qpid::client::no_keyword::Session_0_10::queueDeclare
void 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=true)
qpid::client::no_keyword::Session_0_10::messageStop
void messageStop(const std::string &destination=std::string(), bool sync=true)
uint8_t
unsigned char uint8_t
Definition: IntegerTypes.h:30
qpid::client::no_keyword::Session_0_10::messageResume
qpid::framing::MessageResumeResult messageResume(const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=true)
qpid::client::no_keyword::Session_0_10::messageAccept
void messageAccept(const SequenceSet &transfers=SequenceSet(), bool sync=true)
qpid::client::no_keyword::Session_0_10::dtxGetTimeout
qpid::framing::DtxGetTimeoutResult dtxGetTimeout(const Xid &xid=Xid(), bool sync=true)
qpid::client::no_keyword::Session_0_10::txSelect
void txSelect(bool sync=true)
qpid::client::no_keyword::Session_0_10::messageAcquire
qpid::framing::MessageAcquireResult messageAcquire(const SequenceSet &transfers=SequenceSet(), bool sync=true)
qpid::framing::DtxRecoverResult
Definition: DtxRecoverResult.h:39
qpid::client::no_keyword::Session_0_10::exchangeDeclare
void 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=true)
qpid::framing::XaResult
Definition: XaResult.h:39
qpid::client::no_keyword::Session_0_10::executionSync
void executionSync(bool sync=true)
qpid::client::no_keyword::Session_0_10::messageFlush
void messageFlush(const std::string &destination=std::string(), bool sync=true)
qpid::client::no_keyword::Session_0_10::queueQuery
qpid::framing::QueueQueryResult queueQuery(const std::string &queue=std::string(), bool sync=true)
qpid::client::no_keyword::Session_0_10::dtxForget
void dtxForget(const Xid &xid=Xid(), bool sync=true)
qpid::framing::ExchangeQueryResult
Definition: ExchangeQueryResult.h:39
qpid::framing::DtxGetTimeoutResult
Definition: DtxGetTimeoutResult.h:39
qpid::client::no_keyword::Session_0_10::exchangeDelete
void exchangeDelete(const std::string &exchange=std::string(), bool ifUnused=false, bool sync=true)
qpid::client::no_keyword::Session_0_10::messageTransfer
void messageTransfer(const std::string &destination=std::string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const Message &content=Message(std::string()), bool sync=true)
qpid::client::no_keyword::Session_0_10::queueDelete
void queueDelete(const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=true)
uint32_t
unsigned int uint32_t
Definition: IntegerTypes.h:34
qpid::client::no_keyword::Session_0_10::dtxEnd
qpid::framing::XaResult dtxEnd(const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=true)
qpid::client::no_keyword::Session_0_10::operator=
QPID_CLIENT_INLINE_EXTERN Session_0_10 & operator=(const SessionBase_0_10 &other)
qpid::framing::MessageResumeResult
Definition: MessageResumeResult.h:39
qpid::client::no_keyword::Session_0_10::messageSetFlowMode
void messageSetFlowMode(const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=true)
qpid::client::no_keyword::Session_0_10::dtxRollback
qpid::framing::XaResult dtxRollback(const Xid &xid=Xid(), bool sync=true)
qpid::client::sync
Session_0_10 sync(const SessionBase_0_10 &other)
Conversion to Session_0_10 from another session type.
Definition: Session_0_10.h:553
qpid::client::no_keyword::Session_0_10::messageReject
void messageReject(const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=true)
qpid::client::no_keyword::Session_0_10::dtxStart
qpid::framing::XaResult dtxStart(const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=true)
qpid::client::no_keyword::Session_0_10::txCommit
void txCommit(bool sync=true)
qpid::client::no_keyword::Session_0_10::exchangeBind
void 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=true)
qpid::client::no_keyword::Session_0_10::dtxSetTimeout
void dtxSetTimeout(const Xid &xid=Xid(), uint32_t timeout=0, bool sync=true)
qpid::client::no_keyword::Session_0_10::dtxPrepare
qpid::framing::XaResult dtxPrepare(const Xid &xid=Xid(), bool sync=true)

Qpid C++ API Reference
Generated on Tue Aug 16 2022 for Qpid C++ Client API by doxygen 1.8.17