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

Qpid C++ API Reference
Generated on Mon Aug 22 2011 for Qpid C++ Client API by doxygen 1.7.4