00001 #ifndef QPID_CLIENT_ASYNCSESSION_0_10_H
00002 #define QPID_CLIENT_ASYNCSESSION_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/no_keyword/AsyncSession_0_10.h"
00031 #include "qpid/client/arg.h"
00032
00033 namespace qpid {
00034 namespace client {
00035
00058 class AsyncSession_0_10:
00059 public no_keyword::AsyncSession_0_10
00060 {
00061 public:
00062
00063 AsyncSession_0_10();
00064 AsyncSession_0_10(const SessionBase_0_10& other);
00065 AsyncSession_0_10& operator=(const SessionBase_0_10& other);
00066 private:
00067 typedef boost::parameter::parameters<arg::keyword_tags::commandId,arg::keyword_tags::value> ExecutionResultParameters;
00068
00069 typedef boost::parameter::parameters<arg::keyword_tags::errorCode,arg::keyword_tags::commandId,arg::keyword_tags::classCode,arg::keyword_tags::commandCode,arg::keyword_tags::fieldIndex,arg::keyword_tags::description,arg::keyword_tags::errorInfo> ExecutionExceptionParameters;
00070
00071 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::acceptMode,arg::keyword_tags::acquireMode,arg::keyword_tags::content> MessageTransferParameters;
00072
00073 typedef boost::parameter::parameters<arg::keyword_tags::transfers> MessageAcceptParameters;
00074
00075 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::code,arg::keyword_tags::text> MessageRejectParameters;
00076
00077 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::setRedelivered> MessageReleaseParameters;
00078
00079 typedef boost::parameter::parameters<arg::keyword_tags::transfers> MessageAcquireParameters;
00080
00081 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::resumeId> MessageResumeParameters;
00082
00083 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::destination,arg::keyword_tags::acceptMode,arg::keyword_tags::acquireMode,arg::keyword_tags::exclusive,arg::keyword_tags::resumeId,arg::keyword_tags::resumeTtl,arg::keyword_tags::arguments> MessageSubscribeParameters;
00084
00085 typedef boost::parameter::parameters<arg::keyword_tags::destination> MessageCancelParameters;
00086
00087 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::flowMode> MessageSetFlowModeParameters;
00088
00089 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::unit,arg::keyword_tags::value> MessageFlowParameters;
00090
00091 typedef boost::parameter::parameters<arg::keyword_tags::destination> MessageFlushParameters;
00092
00093 typedef boost::parameter::parameters<arg::keyword_tags::destination> MessageStopParameters;
00094
00095 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::join,arg::keyword_tags::resume> DtxStartParameters;
00096
00097 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::fail,arg::keyword_tags::suspend> DtxEndParameters;
00098
00099 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::onePhase> DtxCommitParameters;
00100
00101 typedef boost::parameter::parameters<arg::keyword_tags::xid> DtxForgetParameters;
00102
00103 typedef boost::parameter::parameters<arg::keyword_tags::xid> DtxGetTimeoutParameters;
00104
00105 typedef boost::parameter::parameters<arg::keyword_tags::xid> DtxPrepareParameters;
00106
00107 typedef boost::parameter::parameters<arg::keyword_tags::xid> DtxRollbackParameters;
00108
00109 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::timeout> DtxSetTimeoutParameters;
00110
00111 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::type,arg::keyword_tags::alternateExchange,arg::keyword_tags::passive,arg::keyword_tags::durable,arg::keyword_tags::autoDelete,arg::keyword_tags::arguments> ExchangeDeclareParameters;
00112
00113 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::ifUnused> ExchangeDeleteParameters;
00114
00115 typedef boost::parameter::parameters<arg::keyword_tags::name> ExchangeQueryParameters;
00116
00117 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey,arg::keyword_tags::arguments> ExchangeBindParameters;
00118
00119 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey> ExchangeUnbindParameters;
00120
00121 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::queue,arg::keyword_tags::bindingKey,arg::keyword_tags::arguments> ExchangeBoundParameters;
00122
00123 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::alternateExchange,arg::keyword_tags::passive,arg::keyword_tags::durable,arg::keyword_tags::exclusive,arg::keyword_tags::autoDelete,arg::keyword_tags::arguments> QueueDeclareParameters;
00124
00125 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::ifUnused,arg::keyword_tags::ifEmpty> QueueDeleteParameters;
00126
00127 typedef boost::parameter::parameters<arg::keyword_tags::queue> QueuePurgeParameters;
00128
00129 typedef boost::parameter::parameters<arg::keyword_tags::queue> QueueQueryParameters;
00130
00131 friend class Connection;
00132 public:
00133 BOOST_PARAMETER_MEMFUN(Completion, executionResult, 0, 2, ExecutionResultParameters) {
00134 return no_keyword::AsyncSession_0_10::executionResult(
00135 p[arg::commandId|SequenceNumber()],
00136 p[arg::value|string()]);
00137 }
00138
00139 BOOST_PARAMETER_MEMFUN(Completion, executionException, 0, 7, ExecutionExceptionParameters) {
00140 return no_keyword::AsyncSession_0_10::executionException(
00141 p[arg::errorCode|0],
00142 p[arg::commandId|SequenceNumber()],
00143 p[arg::classCode|0],
00144 p[arg::commandCode|0],
00145 p[arg::fieldIndex|0],
00146 p[arg::description|string()],
00147 p[arg::errorInfo|FieldTable()]);
00148 }
00149
00150 BOOST_PARAMETER_MEMFUN(Completion, messageTransfer, 0, 4, MessageTransferParameters) {
00151 return no_keyword::AsyncSession_0_10::messageTransfer(
00152 p[arg::destination|string()],
00153 p[arg::acceptMode|1],
00154 p[arg::acquireMode|0],
00155 p[arg::content|DefaultContent(std::string())]);
00156 }
00157
00158 BOOST_PARAMETER_MEMFUN(Completion, messageAccept, 0, 1, MessageAcceptParameters) {
00159 return no_keyword::AsyncSession_0_10::messageAccept(
00160 p[arg::transfers|SequenceSet()]);
00161 }
00162
00163 BOOST_PARAMETER_MEMFUN(Completion, messageReject, 0, 3, MessageRejectParameters) {
00164 return no_keyword::AsyncSession_0_10::messageReject(
00165 p[arg::transfers|SequenceSet()],
00166 p[arg::code|0],
00167 p[arg::text|string()]);
00168 }
00169
00170 BOOST_PARAMETER_MEMFUN(Completion, messageRelease, 0, 2, MessageReleaseParameters) {
00171 return no_keyword::AsyncSession_0_10::messageRelease(
00172 p[arg::transfers|SequenceSet()],
00173 p[arg::setRedelivered|false]);
00174 }
00175
00176 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::MessageAcquireResult>, messageAcquire, 0, 1, MessageAcquireParameters) {
00177 return no_keyword::AsyncSession_0_10::messageAcquire(
00178 p[arg::transfers|SequenceSet()]);
00179 }
00180
00181 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::MessageResumeResult>, messageResume, 0, 2, MessageResumeParameters) {
00182 return no_keyword::AsyncSession_0_10::messageResume(
00183 p[arg::destination|string()],
00184 p[arg::resumeId|string()]);
00185 }
00186
00187 BOOST_PARAMETER_MEMFUN(Completion, messageSubscribe, 0, 8, MessageSubscribeParameters) {
00188 return no_keyword::AsyncSession_0_10::messageSubscribe(
00189 p[arg::queue|string()],
00190 p[arg::destination|string()],
00191 p[arg::acceptMode|0],
00192 p[arg::acquireMode|0],
00193 p[arg::exclusive|false],
00194 p[arg::resumeId|string()],
00195 p[arg::resumeTtl|0],
00196 p[arg::arguments|FieldTable()]);
00197 }
00198
00199 BOOST_PARAMETER_MEMFUN(Completion, messageCancel, 0, 1, MessageCancelParameters) {
00200 return no_keyword::AsyncSession_0_10::messageCancel(
00201 p[arg::destination|string()]);
00202 }
00203
00204 BOOST_PARAMETER_MEMFUN(Completion, messageSetFlowMode, 0, 2, MessageSetFlowModeParameters) {
00205 return no_keyword::AsyncSession_0_10::messageSetFlowMode(
00206 p[arg::destination|string()],
00207 p[arg::flowMode|0]);
00208 }
00209
00210 BOOST_PARAMETER_MEMFUN(Completion, messageFlow, 0, 3, MessageFlowParameters) {
00211 return no_keyword::AsyncSession_0_10::messageFlow(
00212 p[arg::destination|string()],
00213 p[arg::unit|0],
00214 p[arg::value|0]);
00215 }
00216
00217 BOOST_PARAMETER_MEMFUN(Completion, messageFlush, 0, 1, MessageFlushParameters) {
00218 return no_keyword::AsyncSession_0_10::messageFlush(
00219 p[arg::destination|string()]);
00220 }
00221
00222 BOOST_PARAMETER_MEMFUN(Completion, messageStop, 0, 1, MessageStopParameters) {
00223 return no_keyword::AsyncSession_0_10::messageStop(
00224 p[arg::destination|string()]);
00225 }
00226
00227 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxStart, 0, 3, DtxStartParameters) {
00228 return no_keyword::AsyncSession_0_10::dtxStart(
00229 p[arg::xid|Xid()],
00230 p[arg::join|false],
00231 p[arg::resume|false]);
00232 }
00233
00234 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxEnd, 0, 3, DtxEndParameters) {
00235 return no_keyword::AsyncSession_0_10::dtxEnd(
00236 p[arg::xid|Xid()],
00237 p[arg::fail|false],
00238 p[arg::suspend|false]);
00239 }
00240
00241 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxCommit, 0, 2, DtxCommitParameters) {
00242 return no_keyword::AsyncSession_0_10::dtxCommit(
00243 p[arg::xid|Xid()],
00244 p[arg::onePhase|false]);
00245 }
00246
00247 BOOST_PARAMETER_MEMFUN(Completion, dtxForget, 0, 1, DtxForgetParameters) {
00248 return no_keyword::AsyncSession_0_10::dtxForget(
00249 p[arg::xid|Xid()]);
00250 }
00251
00252 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::DtxGetTimeoutResult>, dtxGetTimeout, 0, 1, DtxGetTimeoutParameters) {
00253 return no_keyword::AsyncSession_0_10::dtxGetTimeout(
00254 p[arg::xid|Xid()]);
00255 }
00256
00257 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxPrepare, 0, 1, DtxPrepareParameters) {
00258 return no_keyword::AsyncSession_0_10::dtxPrepare(
00259 p[arg::xid|Xid()]);
00260 }
00261
00262 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxRollback, 0, 1, DtxRollbackParameters) {
00263 return no_keyword::AsyncSession_0_10::dtxRollback(
00264 p[arg::xid|Xid()]);
00265 }
00266
00267 BOOST_PARAMETER_MEMFUN(Completion, dtxSetTimeout, 0, 2, DtxSetTimeoutParameters) {
00268 return no_keyword::AsyncSession_0_10::dtxSetTimeout(
00269 p[arg::xid|Xid()],
00270 p[arg::timeout|0]);
00271 }
00272
00273 BOOST_PARAMETER_MEMFUN(Completion, exchangeDeclare, 0, 7, ExchangeDeclareParameters) {
00274 return no_keyword::AsyncSession_0_10::exchangeDeclare(
00275 p[arg::exchange|string()],
00276 p[arg::type|string()],
00277 p[arg::alternateExchange|string()],
00278 p[arg::passive|false],
00279 p[arg::durable|false],
00280 p[arg::autoDelete|false],
00281 p[arg::arguments|FieldTable()]);
00282 }
00283
00284 BOOST_PARAMETER_MEMFUN(Completion, exchangeDelete, 0, 2, ExchangeDeleteParameters) {
00285 return no_keyword::AsyncSession_0_10::exchangeDelete(
00286 p[arg::exchange|string()],
00287 p[arg::ifUnused|false]);
00288 }
00289
00290 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::ExchangeQueryResult>, exchangeQuery, 0, 1, ExchangeQueryParameters) {
00291 return no_keyword::AsyncSession_0_10::exchangeQuery(
00292 p[arg::name|string()]);
00293 }
00294
00295 BOOST_PARAMETER_MEMFUN(Completion, exchangeBind, 0, 4, ExchangeBindParameters) {
00296 return no_keyword::AsyncSession_0_10::exchangeBind(
00297 p[arg::queue|string()],
00298 p[arg::exchange|string()],
00299 p[arg::bindingKey|string()],
00300 p[arg::arguments|FieldTable()]);
00301 }
00302
00303 BOOST_PARAMETER_MEMFUN(Completion, exchangeUnbind, 0, 3, ExchangeUnbindParameters) {
00304 return no_keyword::AsyncSession_0_10::exchangeUnbind(
00305 p[arg::queue|string()],
00306 p[arg::exchange|string()],
00307 p[arg::bindingKey|string()]);
00308 }
00309
00310 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::ExchangeBoundResult>, exchangeBound, 0, 4, ExchangeBoundParameters) {
00311 return no_keyword::AsyncSession_0_10::exchangeBound(
00312 p[arg::exchange|string()],
00313 p[arg::queue|string()],
00314 p[arg::bindingKey|string()],
00315 p[arg::arguments|FieldTable()]);
00316 }
00317
00318 BOOST_PARAMETER_MEMFUN(Completion, queueDeclare, 0, 7, QueueDeclareParameters) {
00319 return no_keyword::AsyncSession_0_10::queueDeclare(
00320 p[arg::queue|string()],
00321 p[arg::alternateExchange|string()],
00322 p[arg::passive|false],
00323 p[arg::durable|false],
00324 p[arg::exclusive|false],
00325 p[arg::autoDelete|false],
00326 p[arg::arguments|FieldTable()]);
00327 }
00328
00329 BOOST_PARAMETER_MEMFUN(Completion, queueDelete, 0, 3, QueueDeleteParameters) {
00330 return no_keyword::AsyncSession_0_10::queueDelete(
00331 p[arg::queue|string()],
00332 p[arg::ifUnused|false],
00333 p[arg::ifEmpty|false]);
00334 }
00335
00336 BOOST_PARAMETER_MEMFUN(Completion, queuePurge, 0, 1, QueuePurgeParameters) {
00337 return no_keyword::AsyncSession_0_10::queuePurge(
00338 p[arg::queue|string()]);
00339 }
00340
00341 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::QueueQueryResult>, queueQuery, 0, 1, QueueQueryParameters) {
00342 return no_keyword::AsyncSession_0_10::queueQuery(
00343 p[arg::queue|string()]);
00344 }
00345
00346 };
00348 inline AsyncSession_0_10 async(const SessionBase_0_10& other) { return (other); }
00349
00350 inline AsyncSession_0_10::AsyncSession_0_10() {}
00351 inline AsyncSession_0_10::AsyncSession_0_10(const SessionBase_0_10& other) {
00352 *this = other;
00353 }
00354 inline AsyncSession_0_10& AsyncSession_0_10::operator=(const SessionBase_0_10& other) {
00355 impl = static_cast<const AsyncSession_0_10&>(other).impl;
00356 return *this;
00357 }
00358
00359 }}
00360
00361 #endif