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
46
class
AsyncSession_0_10
:
47
public
SessionBase_0_10
48
{
49
public
:
50
51
QPID_CLIENT_EXTERN
AsyncSession_0_10
();
52
QPID_CLIENT_INLINE_EXTERN
AsyncSession_0_10
(
const
SessionBase_0_10
& other);
53
QPID_CLIENT_INLINE_EXTERN
AsyncSession_0_10&
operator=
(
const
SessionBase_0_10
& other);
54
64
QPID_CLIENT_EXTERN
Completion
executionSync
(
bool
sync
=
false
);
65
79
QPID_CLIENT_EXTERN
Completion
executionResult
(
const
SequenceNumber
& commandId=
SequenceNumber
(),
const
std::string& value=std::string(),
bool
sync
=
false
);
80
118
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
);
119
154
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
);
155
171
QPID_CLIENT_EXTERN
Completion
messageAccept
(
const
SequenceSet
& transfers=
SequenceSet
(),
bool
sync
=
false
);
172
200
QPID_CLIENT_EXTERN
Completion
messageReject
(
const
SequenceSet
& transfers=
SequenceSet
(),
uint16_t
code=0,
const
std::string& text=std::string(),
bool
sync
=
false
);
201
226
QPID_CLIENT_EXTERN
Completion
messageRelease
(
const
SequenceSet
& transfers=
SequenceSet
(),
bool
setRedelivered=
false
,
bool
sync
=
false
);
227
243
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::MessageAcquireResult>
messageAcquire
(
const
SequenceSet
& transfers=
SequenceSet
(),
bool
sync
=
false
);
244
267
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::MessageResumeResult>
messageResume
(
const
std::string& destination=std::string(),
const
std::string& resumeId=std::string(),
bool
sync
=
false
);
268
308
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
);
309
324
QPID_CLIENT_EXTERN
Completion
messageCancel
(
const
std::string& destination=std::string(),
bool
sync
=
false
);
325
361
QPID_CLIENT_EXTERN
Completion
messageSetFlowMode
(
const
std::string& destination=std::string(),
uint8_t
flowMode=0,
bool
sync
=
false
);
362
389
QPID_CLIENT_EXTERN
Completion
messageFlow
(
const
std::string& destination=std::string(),
uint8_t
unit=0,
uint32_t
value=0,
bool
sync
=
false
);
390
404
QPID_CLIENT_EXTERN
Completion
messageFlush
(
const
std::string& destination=std::string(),
bool
sync
=
false
);
405
419
QPID_CLIENT_EXTERN
Completion
messageStop
(
const
std::string& destination=std::string(),
bool
sync
=
false
);
420
431
QPID_CLIENT_EXTERN
Completion
txSelect
(
bool
sync
=
false
);
432
443
QPID_CLIENT_EXTERN
Completion
txCommit
(
bool
sync
=
false
);
444
456
QPID_CLIENT_EXTERN
Completion
txRollback
(
bool
sync
=
false
);
457
468
QPID_CLIENT_EXTERN
Completion
dtxSelect
(
bool
sync
=
false
);
469
496
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxStart
(
const
Xid
& xid=
Xid
(),
bool
join=
false
,
bool
resume
=
false
,
bool
sync
=
false
);
497
524
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxEnd
(
const
Xid
& xid=
Xid
(),
bool
fail=
false
,
bool
suspend
=
false
,
bool
sync
=
false
);
525
547
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxCommit
(
const
Xid
& xid=
Xid
(),
bool
onePhase=
false
,
bool
sync
=
false
);
548
563
QPID_CLIENT_EXTERN
Completion
dtxForget
(
const
Xid
& xid=
Xid
(),
bool
sync
=
false
);
564
581
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::DtxGetTimeoutResult>
dtxGetTimeout
(
const
Xid
& xid=
Xid
(),
bool
sync
=
false
);
582
597
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxPrepare
(
const
Xid
& xid=
Xid
(),
bool
sync
=
false
);
598
609
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::DtxRecoverResult>
dtxRecover
(
bool
sync
=
false
);
610
626
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::XaResult>
dtxRollback
(
const
Xid
& xid=
Xid
(),
bool
sync
=
false
);
627
647
QPID_CLIENT_EXTERN
Completion
dtxSetTimeout
(
const
Xid
& xid=
Xid
(),
uint32_t
timeout
=0,
bool
sync
=
false
);
648
704
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
);
705
725
QPID_CLIENT_EXTERN
Completion
exchangeDelete
(
const
std::string& exchange=std::string(),
bool
ifUnused=
false
,
bool
sync
=
false
);
726
742
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::ExchangeQueryResult>
exchangeQuery
(
const
std::string& name=std::string(),
bool
sync
=
false
);
743
770
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
);
771
796
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
);
797
830
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
);
831
892
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
);
893
920
QPID_CLIENT_EXTERN
Completion
queueDelete
(
const
std::string& queue=std::string(),
bool
ifUnused=
false
,
bool
ifEmpty=
false
,
bool
sync
=
false
);
921
937
QPID_CLIENT_EXTERN
Completion
queuePurge
(
const
std::string& queue=std::string(),
bool
sync
=
false
);
938
950
QPID_CLIENT_EXTERN
TypedResult<qpid::framing::QueueQueryResult>
queueQuery
(
const
std::string& queue=std::string(),
bool
sync
=
false
);
951
};
952
953
}}}
// namespace qpid::client::no_keyword
954
955
#endif
Qpid C++ API Reference
Generated on Tue Mar 5 2013 for Qpid C++ Client API by
1.8.1.1