Apache Qpid C++ API
Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET Apache Qpid Documentation

gen/qpid/client/AsyncSession_0_10.h

Go to the documentation of this file.
00001 #ifndef QPID_CLIENT_ASYNCSESSION_0_10_H
00002 #define QPID_CLIENT_ASYNCSESSION_0_10_H
00003 /*
00004  *
00005  * Licensed to the Apache Software Foundation (ASF) under one
00006  * or more contributor license agreements.  See the NOTICE file
00007  * distributed with this work for additional information
00008  * regarding copyright ownership.  The ASF licenses this file
00009  * to you under the Apache License, Version 2.0 (the
00010  * "License"); you may not use this file except in compliance
00011  * with the License.  You may obtain a copy of the License at
00012  *
00013  *   http://www.apache.org/licenses/LICENSE-2.0
00014  *
00015  * Unless required by applicable law or agreed to in writing,
00016  * software distributed under the License is distributed on an
00017  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
00018  * KIND, either express or implied.  See the License for the
00019  * specific language governing permissions and limitations
00020  * under the License.
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 
00188 class AsyncSession_0_10:
00189     public no_keyword::AsyncSession_0_10
00190 {
00191   public:
00192     
00193     AsyncSession_0_10();
00194     AsyncSession_0_10(const SessionBase_0_10& other);
00195     AsyncSession_0_10& operator=(const SessionBase_0_10& other);
00196   private:
00197     typedef boost::parameter::parameters<arg::keyword_tags::sync> ExecutionSyncParameters;
00198     
00199     typedef boost::parameter::parameters<arg::keyword_tags::commandId,arg::keyword_tags::value,arg::keyword_tags::sync> ExecutionResultParameters;
00200     
00201     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,arg::keyword_tags::sync> ExecutionExceptionParameters;
00202     
00203     typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::acceptMode,arg::keyword_tags::acquireMode,arg::keyword_tags::content,arg::keyword_tags::sync> MessageTransferParameters;
00204     
00205     typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::sync> MessageAcceptParameters;
00206     
00207     typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::code,arg::keyword_tags::text,arg::keyword_tags::sync> MessageRejectParameters;
00208     
00209     typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::setRedelivered,arg::keyword_tags::sync> MessageReleaseParameters;
00210     
00211     typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::sync> MessageAcquireParameters;
00212     
00213     typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::resumeId,arg::keyword_tags::sync> MessageResumeParameters;
00214     
00215     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,arg::keyword_tags::sync> MessageSubscribeParameters;
00216     
00217     typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageCancelParameters;
00218     
00219     typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::flowMode,arg::keyword_tags::sync> MessageSetFlowModeParameters;
00220     
00221     typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::unit,arg::keyword_tags::value,arg::keyword_tags::sync> MessageFlowParameters;
00222     
00223     typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageFlushParameters;
00224     
00225     typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageStopParameters;
00226     
00227     typedef boost::parameter::parameters<arg::keyword_tags::sync> TxSelectParameters;
00228     
00229     typedef boost::parameter::parameters<arg::keyword_tags::sync> TxCommitParameters;
00230     
00231     typedef boost::parameter::parameters<arg::keyword_tags::sync> TxRollbackParameters;
00232     
00233     typedef boost::parameter::parameters<arg::keyword_tags::sync> DtxSelectParameters;
00234     
00235     typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::join,arg::keyword_tags::resume,arg::keyword_tags::sync> DtxStartParameters;
00236     
00237     typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::fail,arg::keyword_tags::suspend,arg::keyword_tags::sync> DtxEndParameters;
00238     
00239     typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::onePhase,arg::keyword_tags::sync> DtxCommitParameters;
00240     
00241     typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxForgetParameters;
00242     
00243     typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxGetTimeoutParameters;
00244     
00245     typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxPrepareParameters;
00246     
00247     typedef boost::parameter::parameters<arg::keyword_tags::sync> DtxRecoverParameters;
00248     
00249     typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxRollbackParameters;
00250     
00251     typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::timeout,arg::keyword_tags::sync> DtxSetTimeoutParameters;
00252     
00253     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,arg::keyword_tags::sync> ExchangeDeclareParameters;
00254     
00255     typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::ifUnused,arg::keyword_tags::sync> ExchangeDeleteParameters;
00256     
00257     typedef boost::parameter::parameters<arg::keyword_tags::name,arg::keyword_tags::sync> ExchangeQueryParameters;
00258     
00259     typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey,arg::keyword_tags::arguments,arg::keyword_tags::sync> ExchangeBindParameters;
00260     
00261     typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey,arg::keyword_tags::sync> ExchangeUnbindParameters;
00262     
00263     typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::queue,arg::keyword_tags::bindingKey,arg::keyword_tags::arguments,arg::keyword_tags::sync> ExchangeBoundParameters;
00264     
00265     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,arg::keyword_tags::sync> QueueDeclareParameters;
00266     
00267     typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::ifUnused,arg::keyword_tags::ifEmpty,arg::keyword_tags::sync> QueueDeleteParameters;
00268     
00269     typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::sync> QueuePurgeParameters;
00270     
00271     typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::sync> QueueQueryParameters;
00272     
00273     friend class Connection;
00274   public:
00275     BOOST_PARAMETER_MEMFUN(Completion, executionSync, 0, 1, ExecutionSyncParameters) {
00276         return no_keyword::AsyncSession_0_10::executionSync(
00277             p[arg::sync|false]);
00278     }
00279     
00280     BOOST_PARAMETER_MEMFUN(Completion, executionResult, 0, 3, ExecutionResultParameters) {
00281         return no_keyword::AsyncSession_0_10::executionResult(
00282             p[arg::commandId|SequenceNumber()],
00283             p[arg::value|string()],
00284             p[arg::sync|false]);
00285     }
00286     
00287     BOOST_PARAMETER_MEMFUN(Completion, executionException, 0, 8, ExecutionExceptionParameters) {
00288         return no_keyword::AsyncSession_0_10::executionException(
00289             p[arg::errorCode|0],
00290             p[arg::commandId|SequenceNumber()],
00291             p[arg::classCode|0],
00292             p[arg::commandCode|0],
00293             p[arg::fieldIndex|0],
00294             p[arg::description|string()],
00295             p[arg::errorInfo|FieldTable()],
00296             p[arg::sync|false]);
00297     }
00298     
00299     BOOST_PARAMETER_MEMFUN(Completion, messageTransfer, 0, 5, MessageTransferParameters) {
00300         return no_keyword::AsyncSession_0_10::messageTransfer(
00301             p[arg::destination|string()],
00302             p[arg::acceptMode|1],
00303             p[arg::acquireMode|0],
00304             p[arg::content|DefaultContent(std::string())],
00305             p[arg::sync|false]);
00306     }
00307     
00308     BOOST_PARAMETER_MEMFUN(Completion, messageAccept, 0, 2, MessageAcceptParameters) {
00309         return no_keyword::AsyncSession_0_10::messageAccept(
00310             p[arg::transfers|SequenceSet()],
00311             p[arg::sync|false]);
00312     }
00313     
00314     BOOST_PARAMETER_MEMFUN(Completion, messageReject, 0, 4, MessageRejectParameters) {
00315         return no_keyword::AsyncSession_0_10::messageReject(
00316             p[arg::transfers|SequenceSet()],
00317             p[arg::code|0],
00318             p[arg::text|string()],
00319             p[arg::sync|false]);
00320     }
00321     
00322     BOOST_PARAMETER_MEMFUN(Completion, messageRelease, 0, 3, MessageReleaseParameters) {
00323         return no_keyword::AsyncSession_0_10::messageRelease(
00324             p[arg::transfers|SequenceSet()],
00325             p[arg::setRedelivered|false],
00326             p[arg::sync|false]);
00327     }
00328     
00329     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::MessageAcquireResult>, messageAcquire, 0, 2, MessageAcquireParameters) {
00330         return no_keyword::AsyncSession_0_10::messageAcquire(
00331             p[arg::transfers|SequenceSet()],
00332             p[arg::sync|false]);
00333     }
00334     
00335     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::MessageResumeResult>, messageResume, 0, 3, MessageResumeParameters) {
00336         return no_keyword::AsyncSession_0_10::messageResume(
00337             p[arg::destination|string()],
00338             p[arg::resumeId|string()],
00339             p[arg::sync|false]);
00340     }
00341     
00342     BOOST_PARAMETER_MEMFUN(Completion, messageSubscribe, 0, 9, MessageSubscribeParameters) {
00343         return no_keyword::AsyncSession_0_10::messageSubscribe(
00344             p[arg::queue|string()],
00345             p[arg::destination|string()],
00346             p[arg::acceptMode|0],
00347             p[arg::acquireMode|0],
00348             p[arg::exclusive|false],
00349             p[arg::resumeId|string()],
00350             p[arg::resumeTtl|0],
00351             p[arg::arguments|FieldTable()],
00352             p[arg::sync|false]);
00353     }
00354     
00355     BOOST_PARAMETER_MEMFUN(Completion, messageCancel, 0, 2, MessageCancelParameters) {
00356         return no_keyword::AsyncSession_0_10::messageCancel(
00357             p[arg::destination|string()],
00358             p[arg::sync|false]);
00359     }
00360     
00361     BOOST_PARAMETER_MEMFUN(Completion, messageSetFlowMode, 0, 3, MessageSetFlowModeParameters) {
00362         return no_keyword::AsyncSession_0_10::messageSetFlowMode(
00363             p[arg::destination|string()],
00364             p[arg::flowMode|0],
00365             p[arg::sync|false]);
00366     }
00367     
00368     BOOST_PARAMETER_MEMFUN(Completion, messageFlow, 0, 4, MessageFlowParameters) {
00369         return no_keyword::AsyncSession_0_10::messageFlow(
00370             p[arg::destination|string()],
00371             p[arg::unit|0],
00372             p[arg::value|0],
00373             p[arg::sync|false]);
00374     }
00375     
00376     BOOST_PARAMETER_MEMFUN(Completion, messageFlush, 0, 2, MessageFlushParameters) {
00377         return no_keyword::AsyncSession_0_10::messageFlush(
00378             p[arg::destination|string()],
00379             p[arg::sync|false]);
00380     }
00381     
00382     BOOST_PARAMETER_MEMFUN(Completion, messageStop, 0, 2, MessageStopParameters) {
00383         return no_keyword::AsyncSession_0_10::messageStop(
00384             p[arg::destination|string()],
00385             p[arg::sync|false]);
00386     }
00387     
00388     BOOST_PARAMETER_MEMFUN(Completion, txSelect, 0, 1, TxSelectParameters) {
00389         return no_keyword::AsyncSession_0_10::txSelect(
00390             p[arg::sync|false]);
00391     }
00392     
00393     BOOST_PARAMETER_MEMFUN(Completion, txCommit, 0, 1, TxCommitParameters) {
00394         return no_keyword::AsyncSession_0_10::txCommit(
00395             p[arg::sync|false]);
00396     }
00397     
00398     BOOST_PARAMETER_MEMFUN(Completion, txRollback, 0, 1, TxRollbackParameters) {
00399         return no_keyword::AsyncSession_0_10::txRollback(
00400             p[arg::sync|false]);
00401     }
00402     
00403     BOOST_PARAMETER_MEMFUN(Completion, dtxSelect, 0, 1, DtxSelectParameters) {
00404         return no_keyword::AsyncSession_0_10::dtxSelect(
00405             p[arg::sync|false]);
00406     }
00407     
00408     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxStart, 0, 4, DtxStartParameters) {
00409         return no_keyword::AsyncSession_0_10::dtxStart(
00410             p[arg::xid|Xid()],
00411             p[arg::join|false],
00412             p[arg::resume|false],
00413             p[arg::sync|false]);
00414     }
00415     
00416     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxEnd, 0, 4, DtxEndParameters) {
00417         return no_keyword::AsyncSession_0_10::dtxEnd(
00418             p[arg::xid|Xid()],
00419             p[arg::fail|false],
00420             p[arg::suspend|false],
00421             p[arg::sync|false]);
00422     }
00423     
00424     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxCommit, 0, 3, DtxCommitParameters) {
00425         return no_keyword::AsyncSession_0_10::dtxCommit(
00426             p[arg::xid|Xid()],
00427             p[arg::onePhase|false],
00428             p[arg::sync|false]);
00429     }
00430     
00431     BOOST_PARAMETER_MEMFUN(Completion, dtxForget, 0, 2, DtxForgetParameters) {
00432         return no_keyword::AsyncSession_0_10::dtxForget(
00433             p[arg::xid|Xid()],
00434             p[arg::sync|false]);
00435     }
00436     
00437     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::DtxGetTimeoutResult>, dtxGetTimeout, 0, 2, DtxGetTimeoutParameters) {
00438         return no_keyword::AsyncSession_0_10::dtxGetTimeout(
00439             p[arg::xid|Xid()],
00440             p[arg::sync|false]);
00441     }
00442     
00443     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxPrepare, 0, 2, DtxPrepareParameters) {
00444         return no_keyword::AsyncSession_0_10::dtxPrepare(
00445             p[arg::xid|Xid()],
00446             p[arg::sync|false]);
00447     }
00448     
00449     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::DtxRecoverResult>, dtxRecover, 0, 1, DtxRecoverParameters) {
00450         return no_keyword::AsyncSession_0_10::dtxRecover(
00451             p[arg::sync|false]);
00452     }
00453     
00454     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxRollback, 0, 2, DtxRollbackParameters) {
00455         return no_keyword::AsyncSession_0_10::dtxRollback(
00456             p[arg::xid|Xid()],
00457             p[arg::sync|false]);
00458     }
00459     
00460     BOOST_PARAMETER_MEMFUN(Completion, dtxSetTimeout, 0, 3, DtxSetTimeoutParameters) {
00461         return no_keyword::AsyncSession_0_10::dtxSetTimeout(
00462             p[arg::xid|Xid()],
00463             p[arg::timeout|0],
00464             p[arg::sync|false]);
00465     }
00466     
00467     BOOST_PARAMETER_MEMFUN(Completion, exchangeDeclare, 0, 8, ExchangeDeclareParameters) {
00468         return no_keyword::AsyncSession_0_10::exchangeDeclare(
00469             p[arg::exchange|string()],
00470             p[arg::type|string()],
00471             p[arg::alternateExchange|string()],
00472             p[arg::passive|false],
00473             p[arg::durable|false],
00474             p[arg::autoDelete|false],
00475             p[arg::arguments|FieldTable()],
00476             p[arg::sync|false]);
00477     }
00478     
00479     BOOST_PARAMETER_MEMFUN(Completion, exchangeDelete, 0, 3, ExchangeDeleteParameters) {
00480         return no_keyword::AsyncSession_0_10::exchangeDelete(
00481             p[arg::exchange|string()],
00482             p[arg::ifUnused|false],
00483             p[arg::sync|false]);
00484     }
00485     
00486     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::ExchangeQueryResult>, exchangeQuery, 0, 2, ExchangeQueryParameters) {
00487         return no_keyword::AsyncSession_0_10::exchangeQuery(
00488             p[arg::name|string()],
00489             p[arg::sync|false]);
00490     }
00491     
00492     BOOST_PARAMETER_MEMFUN(Completion, exchangeBind, 0, 5, ExchangeBindParameters) {
00493         return no_keyword::AsyncSession_0_10::exchangeBind(
00494             p[arg::queue|string()],
00495             p[arg::exchange|string()],
00496             p[arg::bindingKey|string()],
00497             p[arg::arguments|FieldTable()],
00498             p[arg::sync|false]);
00499     }
00500     
00501     BOOST_PARAMETER_MEMFUN(Completion, exchangeUnbind, 0, 4, ExchangeUnbindParameters) {
00502         return no_keyword::AsyncSession_0_10::exchangeUnbind(
00503             p[arg::queue|string()],
00504             p[arg::exchange|string()],
00505             p[arg::bindingKey|string()],
00506             p[arg::sync|false]);
00507     }
00508     
00509     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::ExchangeBoundResult>, exchangeBound, 0, 5, ExchangeBoundParameters) {
00510         return no_keyword::AsyncSession_0_10::exchangeBound(
00511             p[arg::exchange|string()],
00512             p[arg::queue|string()],
00513             p[arg::bindingKey|string()],
00514             p[arg::arguments|FieldTable()],
00515             p[arg::sync|false]);
00516     }
00517     
00518     BOOST_PARAMETER_MEMFUN(Completion, queueDeclare, 0, 8, QueueDeclareParameters) {
00519         return no_keyword::AsyncSession_0_10::queueDeclare(
00520             p[arg::queue|string()],
00521             p[arg::alternateExchange|string()],
00522             p[arg::passive|false],
00523             p[arg::durable|false],
00524             p[arg::exclusive|false],
00525             p[arg::autoDelete|false],
00526             p[arg::arguments|FieldTable()],
00527             p[arg::sync|false]);
00528     }
00529     
00530     BOOST_PARAMETER_MEMFUN(Completion, queueDelete, 0, 4, QueueDeleteParameters) {
00531         return no_keyword::AsyncSession_0_10::queueDelete(
00532             p[arg::queue|string()],
00533             p[arg::ifUnused|false],
00534             p[arg::ifEmpty|false],
00535             p[arg::sync|false]);
00536     }
00537     
00538     BOOST_PARAMETER_MEMFUN(Completion, queuePurge, 0, 2, QueuePurgeParameters) {
00539         return no_keyword::AsyncSession_0_10::queuePurge(
00540             p[arg::queue|string()],
00541             p[arg::sync|false]);
00542     }
00543     
00544     BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::QueueQueryResult>, queueQuery, 0, 2, QueueQueryParameters) {
00545         return no_keyword::AsyncSession_0_10::queueQuery(
00546             p[arg::queue|string()],
00547             p[arg::sync|false]);
00548     }
00549     
00550 };
00552 inline AsyncSession_0_10 async(const SessionBase_0_10& other) { return (other); }
00553 
00554 inline AsyncSession_0_10::AsyncSession_0_10() {}
00555 inline AsyncSession_0_10::AsyncSession_0_10(const SessionBase_0_10& other) {
00556     *this = other;
00557 }
00558 inline AsyncSession_0_10& AsyncSession_0_10::operator=(const SessionBase_0_10& other) {
00559     impl = static_cast<const AsyncSession_0_10&>(other).impl;
00560     return *this;
00561 }
00562 
00563 }} // namespace qpid::client
00564 
00565 #endif  

Qpid C++ API Reference
Generated on Tue Dec 8 15:39:46 2009 for Qpid C++ Client API by doxygen 1.4.7