Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET Apache Qpid Documentation
Session_0_10.h
Go to the documentation of this file.
1 #ifndef QPID_CLIENT_SESSION_0_10_H
2 #define QPID_CLIENT_SESSION_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 
31 #include "qpid/client/arg.h"
32 #include "qpid/client/ClientImportExport.h"
33 
34 namespace qpid {
35 namespace client {
36 
191 {
192  public:
193 
194  QPID_CLIENT_EXTERN Session_0_10();
195  QPID_CLIENT_INLINE_EXTERN Session_0_10(const SessionBase_0_10& other);
196  QPID_CLIENT_INLINE_EXTERN Session_0_10& operator=(const SessionBase_0_10& other);
197  private:
198  typedef boost::parameter::parameters<arg::keyword_tags::sync> ExecutionSyncParameters;
199 
200  typedef boost::parameter::parameters<arg::keyword_tags::commandId,arg::keyword_tags::value,arg::keyword_tags::sync> ExecutionResultParameters;
201 
202  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;
203 
204  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;
205 
206  typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::sync> MessageAcceptParameters;
207 
208  typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::code,arg::keyword_tags::text,arg::keyword_tags::sync> MessageRejectParameters;
209 
210  typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::setRedelivered,arg::keyword_tags::sync> MessageReleaseParameters;
211 
212  typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::sync> MessageAcquireParameters;
213 
214  typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::resumeId,arg::keyword_tags::sync> MessageResumeParameters;
215 
216  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;
217 
218  typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageCancelParameters;
219 
220  typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::flowMode,arg::keyword_tags::sync> MessageSetFlowModeParameters;
221 
222  typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::unit,arg::keyword_tags::value,arg::keyword_tags::sync> MessageFlowParameters;
223 
224  typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageFlushParameters;
225 
226  typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageStopParameters;
227 
228  typedef boost::parameter::parameters<arg::keyword_tags::sync> TxSelectParameters;
229 
230  typedef boost::parameter::parameters<arg::keyword_tags::sync> TxCommitParameters;
231 
232  typedef boost::parameter::parameters<arg::keyword_tags::sync> TxRollbackParameters;
233 
234  typedef boost::parameter::parameters<arg::keyword_tags::sync> DtxSelectParameters;
235 
236  typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::join,arg::keyword_tags::resume,arg::keyword_tags::sync> DtxStartParameters;
237 
238  typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::fail,arg::keyword_tags::suspend,arg::keyword_tags::sync> DtxEndParameters;
239 
240  typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::onePhase,arg::keyword_tags::sync> DtxCommitParameters;
241 
242  typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxForgetParameters;
243 
244  typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxGetTimeoutParameters;
245 
246  typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxPrepareParameters;
247 
248  typedef boost::parameter::parameters<arg::keyword_tags::sync> DtxRecoverParameters;
249 
250  typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxRollbackParameters;
251 
252  typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::timeout,arg::keyword_tags::sync> DtxSetTimeoutParameters;
253 
254  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;
255 
256  typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::ifUnused,arg::keyword_tags::sync> ExchangeDeleteParameters;
257 
258  typedef boost::parameter::parameters<arg::keyword_tags::name,arg::keyword_tags::sync> ExchangeQueryParameters;
259 
260  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;
261 
262  typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey,arg::keyword_tags::sync> ExchangeUnbindParameters;
263 
264  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;
265 
266  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;
267 
268  typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::ifUnused,arg::keyword_tags::ifEmpty,arg::keyword_tags::sync> QueueDeleteParameters;
269 
270  typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::sync> QueuePurgeParameters;
271 
272  typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::sync> QueueQueryParameters;
273 
274  friend class Connection;
275  public:
276  BOOST_PARAMETER_MEMFUN(void, executionSync, 0, 1, ExecutionSyncParameters) {
278  p[arg::sync|true]);
279  }
280 
281  BOOST_PARAMETER_MEMFUN(void, executionResult, 0, 3, ExecutionResultParameters) {
283  p[arg::commandId|SequenceNumber()],
284  p[arg::value|std::string()],
285  p[arg::sync|true]);
286  }
287 
288  BOOST_PARAMETER_MEMFUN(void, executionException, 0, 8, ExecutionExceptionParameters) {
290  p[arg::errorCode|0],
291  p[arg::commandId|SequenceNumber()],
292  p[arg::classCode|0],
293  p[arg::commandCode|0],
294  p[arg::fieldIndex|0],
295  p[arg::description|std::string()],
296  p[arg::errorInfo|FieldTable()],
297  p[arg::sync|true]);
298  }
299 
300  BOOST_PARAMETER_MEMFUN(void, messageTransfer, 0, 5, MessageTransferParameters) {
302  p[arg::destination|std::string()],
303  p[arg::acceptMode|1],
304  p[arg::acquireMode|0],
305  p[arg::content|Message(std::string())],
306  p[arg::sync|true]);
307  }
308 
309  BOOST_PARAMETER_MEMFUN(void, messageAccept, 0, 2, MessageAcceptParameters) {
311  p[arg::transfers|SequenceSet()],
312  p[arg::sync|true]);
313  }
314 
315  BOOST_PARAMETER_MEMFUN(void, messageReject, 0, 4, MessageRejectParameters) {
317  p[arg::transfers|SequenceSet()],
318  p[arg::code|0],
319  p[arg::text|std::string()],
320  p[arg::sync|true]);
321  }
322 
323  BOOST_PARAMETER_MEMFUN(void, messageRelease, 0, 3, MessageReleaseParameters) {
325  p[arg::transfers|SequenceSet()],
326  p[arg::setRedelivered|false],
327  p[arg::sync|true]);
328  }
329 
332  p[arg::transfers|SequenceSet()],
333  p[arg::sync|true]);
334  }
335 
338  p[arg::destination|std::string()],
339  p[arg::resumeId|std::string()],
340  p[arg::sync|true]);
341  }
342 
343  BOOST_PARAMETER_MEMFUN(void, messageSubscribe, 0, 9, MessageSubscribeParameters) {
345  p[arg::queue|std::string()],
346  p[arg::destination|std::string()],
347  p[arg::acceptMode|0],
348  p[arg::acquireMode|0],
349  p[arg::exclusive|false],
350  p[arg::resumeId|std::string()],
351  p[arg::resumeTtl|0],
352  p[arg::arguments|FieldTable()],
353  p[arg::sync|true]);
354  }
355 
356  BOOST_PARAMETER_MEMFUN(void, messageCancel, 0, 2, MessageCancelParameters) {
358  p[arg::destination|std::string()],
359  p[arg::sync|true]);
360  }
361 
362  BOOST_PARAMETER_MEMFUN(void, messageSetFlowMode, 0, 3, MessageSetFlowModeParameters) {
364  p[arg::destination|std::string()],
365  p[arg::flowMode|0],
366  p[arg::sync|true]);
367  }
368 
369  BOOST_PARAMETER_MEMFUN(void, messageFlow, 0, 4, MessageFlowParameters) {
371  p[arg::destination|std::string()],
372  p[arg::unit|0],
373  p[arg::value|0],
374  p[arg::sync|true]);
375  }
376 
377  BOOST_PARAMETER_MEMFUN(void, messageFlush, 0, 2, MessageFlushParameters) {
379  p[arg::destination|std::string()],
380  p[arg::sync|true]);
381  }
382 
383  BOOST_PARAMETER_MEMFUN(void, messageStop, 0, 2, MessageStopParameters) {
385  p[arg::destination|std::string()],
386  p[arg::sync|true]);
387  }
388 
389  BOOST_PARAMETER_MEMFUN(void, txSelect, 0, 1, TxSelectParameters) {
391  p[arg::sync|true]);
392  }
393 
394  BOOST_PARAMETER_MEMFUN(void, txCommit, 0, 1, TxCommitParameters) {
396  p[arg::sync|true]);
397  }
398 
399  BOOST_PARAMETER_MEMFUN(void, txRollback, 0, 1, TxRollbackParameters) {
401  p[arg::sync|true]);
402  }
403 
404  BOOST_PARAMETER_MEMFUN(void, dtxSelect, 0, 1, DtxSelectParameters) {
406  p[arg::sync|true]);
407  }
408 
411  p[arg::xid|Xid()],
412  p[arg::join|false],
413  p[arg::resume|false],
414  p[arg::sync|true]);
415  }
416 
419  p[arg::xid|Xid()],
420  p[arg::fail|false],
421  p[arg::suspend|false],
422  p[arg::sync|true]);
423  }
424 
427  p[arg::xid|Xid()],
428  p[arg::onePhase|false],
429  p[arg::sync|true]);
430  }
431 
432  BOOST_PARAMETER_MEMFUN(void, dtxForget, 0, 2, DtxForgetParameters) {
434  p[arg::xid|Xid()],
435  p[arg::sync|true]);
436  }
437 
440  p[arg::xid|Xid()],
441  p[arg::sync|true]);
442  }
443 
446  p[arg::xid|Xid()],
447  p[arg::sync|true]);
448  }
449 
452  p[arg::sync|true]);
453  }
454 
457  p[arg::xid|Xid()],
458  p[arg::sync|true]);
459  }
460 
461  BOOST_PARAMETER_MEMFUN(void, dtxSetTimeout, 0, 3, DtxSetTimeoutParameters) {
463  p[arg::xid|Xid()],
464  p[arg::timeout|0],
465  p[arg::sync|true]);
466  }
467 
468  BOOST_PARAMETER_MEMFUN(void, exchangeDeclare, 0, 8, ExchangeDeclareParameters) {
470  p[arg::exchange|std::string()],
471  p[arg::type|std::string()],
472  p[arg::alternateExchange|std::string()],
473  p[arg::passive|false],
474  p[arg::durable|false],
475  p[arg::autoDelete|false],
476  p[arg::arguments|FieldTable()],
477  p[arg::sync|true]);
478  }
479 
480  BOOST_PARAMETER_MEMFUN(void, exchangeDelete, 0, 3, ExchangeDeleteParameters) {
482  p[arg::exchange|std::string()],
483  p[arg::ifUnused|false],
484  p[arg::sync|true]);
485  }
486 
489  p[arg::name|std::string()],
490  p[arg::sync|true]);
491  }
492 
493  BOOST_PARAMETER_MEMFUN(void, exchangeBind, 0, 5, ExchangeBindParameters) {
495  p[arg::queue|std::string()],
496  p[arg::exchange|std::string()],
497  p[arg::bindingKey|std::string()],
498  p[arg::arguments|FieldTable()],
499  p[arg::sync|true]);
500  }
501 
502  BOOST_PARAMETER_MEMFUN(void, exchangeUnbind, 0, 4, ExchangeUnbindParameters) {
504  p[arg::queue|std::string()],
505  p[arg::exchange|std::string()],
506  p[arg::bindingKey|std::string()],
507  p[arg::sync|true]);
508  }
509 
512  p[arg::exchange|std::string()],
513  p[arg::queue|std::string()],
514  p[arg::bindingKey|std::string()],
515  p[arg::arguments|FieldTable()],
516  p[arg::sync|true]);
517  }
518 
519  BOOST_PARAMETER_MEMFUN(void, queueDeclare, 0, 8, QueueDeclareParameters) {
521  p[arg::queue|std::string()],
522  p[arg::alternateExchange|std::string()],
523  p[arg::passive|false],
524  p[arg::durable|false],
525  p[arg::exclusive|false],
526  p[arg::autoDelete|false],
527  p[arg::arguments|FieldTable()],
528  p[arg::sync|true]);
529  }
530 
531  BOOST_PARAMETER_MEMFUN(void, queueDelete, 0, 4, QueueDeleteParameters) {
533  p[arg::queue|std::string()],
534  p[arg::ifUnused|false],
535  p[arg::ifEmpty|false],
536  p[arg::sync|true]);
537  }
538 
539  BOOST_PARAMETER_MEMFUN(void, queuePurge, 0, 2, QueuePurgeParameters) {
541  p[arg::queue|std::string()],
542  p[arg::sync|true]);
543  }
544 
547  p[arg::queue|std::string()],
548  p[arg::sync|true]);
549  }
550 
551 };
553 inline Session_0_10 sync(const SessionBase_0_10& other) { return (other); }
554 
556 inline Session_0_10::Session_0_10(const SessionBase_0_10& other) {
557  *this = other;
558 }
559 inline Session_0_10& Session_0_10::operator=(const SessionBase_0_10& other) {
560  impl = static_cast<const Session_0_10&>(other).impl;
561  return *this;
562 }
563 
564 }} // namespace qpid::client
565 
566 #endif
void queuePurge(const std::string &queue=std::string(), bool sync=true)
qpid::framing::MessageAcquireResult messageAcquire(const SequenceSet &transfers=SequenceSet(), bool sync=true)
void messageAccept(const SequenceSet &transfers=SequenceSet(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, queueDelete, 0, 4, QueueDeleteParameters)
Definition: Session_0_10.h:531
void messageTransfer(const std::string &destination=std::string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const Message &content=Message(std::string()), bool sync=true)
void messageReject(const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, messageTransfer, 0, 5, MessageTransferParameters)
Definition: Session_0_10.h:300
BOOST_PARAMETER_MEMFUN(void, messageFlush, 0, 2, MessageFlushParameters)
Definition: Session_0_10.h:377
void dtxForget(const Xid &xid=Xid(), bool sync=true)
void messageFlush(const std::string &destination=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::DtxGetTimeoutResult, dtxGetTimeout, 0, 2, DtxGetTimeoutParameters)
Definition: Session_0_10.h:438
AMQP 0-10 synchronous session API.
Definition: Session_0_10.h:40
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxPrepare, 0, 2, DtxPrepareParameters)
Definition: Session_0_10.h:444
qpid::framing::XaResult dtxRollback(const Xid &xid=Xid(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, messageReject, 0, 4, MessageRejectParameters)
Definition: Session_0_10.h:315
QPID_CLIENT_INLINE_EXTERN Session_0_10 & operator=(const SessionBase_0_10 &other)
Definition: Session_0_10.h:559
BOOST_PARAMETER_MEMFUN(void, txCommit, 0, 1, TxCommitParameters)
Definition: Session_0_10.h:394
BOOST_PARAMETER_MEMFUN(void, queueDeclare, 0, 8, QueueDeclareParameters)
Definition: Session_0_10.h:519
qpid::framing::ExchangeQueryResult exchangeQuery(const std::string &name=std::string(), bool sync=true)
void 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=true)
void exchangeUnbind(const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=true)
void executionResult(const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxRollback, 0, 2, DtxRollbackParameters)
Definition: Session_0_10.h:455
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=true)
BOOST_PARAMETER_MEMFUN(void, messageSubscribe, 0, 9, MessageSubscribeParameters)
Definition: Session_0_10.h:343
BOOST_PARAMETER_MEMFUN(void, exchangeDelete, 0, 3, ExchangeDeleteParameters)
Definition: Session_0_10.h:480
BOOST_PARAMETER_MEMFUN(qpid::framing::QueueQueryResult, queueQuery, 0, 2, QueueQueryParameters)
Definition: Session_0_10.h:545
BOOST_PARAMETER_MEMFUN(void, messageCancel, 0, 2, MessageCancelParameters)
Definition: Session_0_10.h:356
BOOST_PARAMETER_MEMFUN(void, messageStop, 0, 2, MessageStopParameters)
Definition: Session_0_10.h:383
AMQP 0-10 session API with keyword arguments.
Definition: Session_0_10.h:189
qpid::framing::XaResult dtxPrepare(const Xid &xid=Xid(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, exchangeUnbind, 0, 4, ExchangeUnbindParameters)
Definition: Session_0_10.h:502
BOOST_PARAMETER_MEMFUN(void, txSelect, 0, 1, TxSelectParameters)
Definition: Session_0_10.h:389
qpid::framing::XaResult dtxEnd(const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=true)
qpid::framing::MessageResumeResult messageResume(const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::MessageAcquireResult, messageAcquire, 0, 2, MessageAcquireParameters)
Definition: Session_0_10.h:330
void messageFlow(const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxCommit, 0, 3, DtxCommitParameters)
Definition: Session_0_10.h:425
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxStart, 0, 4, DtxStartParameters)
Definition: Session_0_10.h:409
qpid::framing::XaResult dtxCommit(const Xid &xid=Xid(), bool onePhase=false, bool sync=true)
void exchangeDelete(const std::string &exchange=std::string(), bool ifUnused=false, bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::DtxRecoverResult, dtxRecover, 0, 1, DtxRecoverParameters)
Definition: Session_0_10.h:450
void 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=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::ExchangeBoundResult, exchangeBound, 0, 5, ExchangeBoundParameters)
Definition: Session_0_10.h:510
void 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=true)
void 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=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxEnd, 0, 4, DtxEndParameters)
Definition: Session_0_10.h:417
BOOST_PARAMETER_MEMFUN(void, messageAccept, 0, 2, MessageAcceptParameters)
Definition: Session_0_10.h:309
BOOST_PARAMETER_MEMFUN(void, executionSync, 0, 1, ExecutionSyncParameters)
Definition: Session_0_10.h:276
BOOST_PARAMETER_MEMFUN(void, exchangeDeclare, 0, 8, ExchangeDeclareParameters)
Definition: Session_0_10.h:468
BOOST_PARAMETER_MEMFUN(void, dtxSelect, 0, 1, DtxSelectParameters)
Definition: Session_0_10.h:404
BOOST_PARAMETER_MEMFUN(void, txRollback, 0, 1, TxRollbackParameters)
Definition: Session_0_10.h:399
BOOST_PARAMETER_MEMFUN(void, exchangeBind, 0, 5, ExchangeBindParameters)
Definition: Session_0_10.h:493
BOOST_PARAMETER_MEMFUN(void, messageFlow, 0, 4, MessageFlowParameters)
Definition: Session_0_10.h:369
Session_0_10 sync(const SessionBase_0_10 &other)
Conversion to Session_0_10 from another session type.
Definition: Session_0_10.h:553
BOOST_PARAMETER_MEMFUN(qpid::framing::MessageResumeResult, messageResume, 0, 3, MessageResumeParameters)
Definition: Session_0_10.h:336
void messageCancel(const std::string &destination=std::string(), bool sync=true)
void messageRelease(const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=true)
qpid::framing::DtxGetTimeoutResult dtxGetTimeout(const Xid &xid=Xid(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, queuePurge, 0, 2, QueuePurgeParameters)
Definition: Session_0_10.h:539
BOOST_PARAMETER_MEMFUN(void, messageRelease, 0, 3, MessageReleaseParameters)
Definition: Session_0_10.h:323
void queueDelete(const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=true)
BOOST_PARAMETER_MEMFUN(void, messageSetFlowMode, 0, 3, MessageSetFlowModeParameters)
Definition: Session_0_10.h:362
void messageStop(const std::string &destination=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, executionException, 0, 8, ExecutionExceptionParameters)
Definition: Session_0_10.h:288
BOOST_PARAMETER_MEMFUN(void, dtxSetTimeout, 0, 3, DtxSetTimeoutParameters)
Definition: Session_0_10.h:461
BOOST_PARAMETER_MEMFUN(qpid::framing::ExchangeQueryResult, exchangeQuery, 0, 2, ExchangeQueryParameters)
Definition: Session_0_10.h:487
void 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=true)
qpid::framing::XaResult dtxStart(const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=true)
qpid::framing::QueueQueryResult queueQuery(const std::string &queue=std::string(), bool sync=true)
void messageSetFlowMode(const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=true)
void dtxSetTimeout(const Xid &xid=Xid(), uint32_t timeout=0, bool sync=true)
qpid::framing::DtxRecoverResult dtxRecover(bool sync=true)
BOOST_PARAMETER_MEMFUN(void, dtxForget, 0, 2, DtxForgetParameters)
Definition: Session_0_10.h:432
BOOST_PARAMETER_MEMFUN(void, executionResult, 0, 3, ExecutionResultParameters)
Definition: Session_0_10.h:281

Qpid C++ API Reference
Generated on Tue Oct 28 2014 for Qpid C++ Client API by doxygen 1.8.5