Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET
Apache Qpid Documentation
Main Page
Modules
Namespaces
Classes
Files
File List
File Members
qpid
client
no_keyword
AsyncSession_0_10.h
Go to the documentation of this file.
1
#ifndef QPID_CLIENT_NO_KEYWORD_ASYNCSESSION_0_10_H
2
#define QPID_CLIENT_NO_KEYWORD_ASYNCSESSION_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
40
class
AsyncSession_0_10
:
41
public
SessionBase_0_10
42
{
43
public
:
44
45
QPID_CLIENT_EXTERN
AsyncSession_0_10
();
46
QPID_CLIENT_INLINE_EXTERN
AsyncSession_0_10
(
const
SessionBase_0_10
& other);
47
QPID_CLIENT_INLINE_EXTERN
AsyncSession_0_10&
operator=
(
const
SessionBase_0_10
& other);
48
49
QPID_CLIENT_EXTERN
Completion
executionSync
(
bool
sync
=
false
);
50
51
QPID_CLIENT_EXTERN
Completion
executionResult
(
const
SequenceNumber
& commandId=
SequenceNumber
(),
const
std::string& value=std::string(),
bool
sync
=
false
);
52
53
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
);
54
55
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
);
56
57
QPID_CLIENT_EXTERN
Completion
messageAccept
(
const
SequenceSet
& transfers=
SequenceSet
(),
bool
sync
=
false
);
58
59
QPID_CLIENT_EXTERN
Completion
messageReject
(
const
SequenceSet
& transfers=
SequenceSet
(),
uint16_t
code=0,
const
std::string& text=std::string(),
bool
sync
=
false
);
60
61
QPID_CLIENT_EXTERN
Completion
messageRelease
(
const
SequenceSet
& transfers=
SequenceSet
(),
bool
setRedelivered=
false
,
bool
sync
=
false
);
62
63
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::MessageAcquireResult>
messageAcquire
(
const
SequenceSet
& transfers=
SequenceSet
(),
bool
sync
=
false
);
64
65
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::MessageResumeResult>
messageResume
(
const
std::string& destination=std::string(),
const
std::string& resumeId=std::string(),
bool
sync
=
false
);
66
67
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
);
68
69
QPID_CLIENT_EXTERN
Completion
messageCancel
(
const
std::string& destination=std::string(),
bool
sync
=
false
);
70
71
QPID_CLIENT_EXTERN
Completion
messageSetFlowMode
(
const
std::string& destination=std::string(),
uint8_t
flowMode=0,
bool
sync
=
false
);
72
73
QPID_CLIENT_EXTERN
Completion
messageFlow
(
const
std::string& destination=std::string(),
uint8_t
unit=0,
uint32_t
value=0,
bool
sync
=
false
);
74
75
QPID_CLIENT_EXTERN
Completion
messageFlush
(
const
std::string& destination=std::string(),
bool
sync
=
false
);
76
77
QPID_CLIENT_EXTERN
Completion
messageStop
(
const
std::string& destination=std::string(),
bool
sync
=
false
);
78
79
QPID_CLIENT_EXTERN
Completion
txSelect
(
bool
sync
=
false
);
80
81
QPID_CLIENT_EXTERN
Completion
txCommit
(
bool
sync
=
false
);
82
83
QPID_CLIENT_EXTERN
Completion
txRollback
(
bool
sync
=
false
);
84
85
QPID_CLIENT_EXTERN
Completion
dtxSelect
(
bool
sync
=
false
);
86
87
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxStart
(
const
Xid
& xid=
Xid
(),
bool
join=
false
,
bool
resume
=
false
,
bool
sync
=
false
);
88
89
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxEnd
(
const
Xid
& xid=
Xid
(),
bool
fail=
false
,
bool
suspend
=
false
,
bool
sync
=
false
);
90
91
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxCommit
(
const
Xid
& xid=
Xid
(),
bool
onePhase=
false
,
bool
sync
=
false
);
92
93
QPID_CLIENT_EXTERN
Completion
dtxForget
(
const
Xid
& xid=
Xid
(),
bool
sync
=
false
);
94
95
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::DtxGetTimeoutResult>
dtxGetTimeout
(
const
Xid
& xid=
Xid
(),
bool
sync
=
false
);
96
97
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxPrepare
(
const
Xid
& xid=
Xid
(),
bool
sync
=
false
);
98
99
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::DtxRecoverResult>
dtxRecover
(
bool
sync
=
false
);
100
101
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxRollback
(
const
Xid
& xid=
Xid
(),
bool
sync
=
false
);
102
103
QPID_CLIENT_EXTERN
Completion
dtxSetTimeout
(
const
Xid
& xid=
Xid
(),
uint32_t
timeout
=0,
bool
sync
=
false
);
104
105
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
);
106
107
QPID_CLIENT_EXTERN
Completion
exchangeDelete
(
const
std::string& exchange=std::string(),
bool
ifUnused=
false
,
bool
sync
=
false
);
108
109
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::ExchangeQueryResult>
exchangeQuery
(
const
std::string& name=std::string(),
bool
sync
=
false
);
110
111
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
);
112
113
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
);
114
115
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
);
116
117
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
);
118
119
QPID_CLIENT_EXTERN
Completion
queueDelete
(
const
std::string& queue=std::string(),
bool
ifUnused=
false
,
bool
ifEmpty=
false
,
bool
sync
=
false
);
120
121
QPID_CLIENT_EXTERN
Completion
queuePurge
(
const
std::string& queue=std::string(),
bool
sync
=
false
);
122
123
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::QueueQueryResult>
queueQuery
(
const
std::string& queue=std::string(),
bool
sync
=
false
);
124
};
125
126
}}}
// namespace qpid::client::no_keyword
127
128
#endif
Qpid C++ API Reference
Generated on Thu Jun 13 2013 for Qpid C++ Client API by
1.8.1.1