Class: Cqpid::Session
- Inherits:
-
Object
- Object
- Cqpid::Session
- Defined in:
- ext/cqpid/cqpid.cpp
Instance Method Summary collapse
- #acknowledge(*args, self) ⇒ Object
- #acknowledgeUpTo(*args, self) ⇒ Object
- #checkError(*args) ⇒ Object
- #close(*args) ⇒ Object
- #commit(*args) ⇒ Object
- #createReceiver(*args, self) ⇒ Object
- #createSender(*args, self) ⇒ Object
- #getConnection(*args) ⇒ Object
- #getReceivable(*args) ⇒ Object
- #getReceiver(*args) ⇒ Object
- #getSender(*args) ⇒ Object
- #getUnsettledAcks(*args) ⇒ Object
- #hasError(*args) ⇒ Object
- #initialize(*args, self) ⇒ Object constructor
- #nextReceiver(*args, self) ⇒ Object
-
#reject(*args) ⇒ Object
call-seq: reject(arg2).
- #release(*args) ⇒ Object
- #rollback(*args) ⇒ Object
- #sync(*args, self) ⇒ Object
Constructor Details
#initialize(*args, self) ⇒ Object
16439 16440 16441 16442 16443 16444 16445 16446 16447 16448 16449 16450 16451 16452 16453 16454 16455 16456 16457 16458 16459 16460 16461 16462 16463 16464 16465 16466 16467 16468 16469 16470 16471 16472 16473 16474 16475 16476 16477 16478 |
# File 'ext/cqpid/cqpid.cpp', line 16439
SWIGINTERN VALUE _wrap_new_Session(int nargs, VALUE *args, VALUE self) {
int argc;
VALUE argv[1];
int ii;
argc = nargs;
if (argc > 1) SWIG_fail;
for (ii = 0; (ii < argc); ++ii) {
argv[ii] = args[ii];
}
if (argc == 0) {
return _wrap_new_Session__SWIG_1(nargs, args, self);
}
if (argc == 1) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__SessionImpl, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_new_Session__SWIG_0(nargs, args, self);
}
}
if (argc == 1) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_new_Session__SWIG_2(nargs, args, self);
}
}
fail:
Ruby_Format_OverloadedError( argc, 1, "Session.new",
" Session.new(qpid::messaging::SessionImpl *impl)\n"
" Session.new()\n"
" Session.new(qpid::messaging::Session const &)\n");
return Qnil;
}
|
Instance Method Details
#acknowledge(*args, self) ⇒ Object
17330 17331 17332 17333 17334 17335 17336 17337 17338 17339 17340 17341 17342 17343 17344 17345 17346 17347 17348 17349 17350 17351 17352 17353 17354 17355 17356 17357 17358 17359 17360 17361 17362 17363 17364 17365 17366 17367 17368 17369 17370 17371 17372 17373 17374 17375 17376 17377 17378 17379 17380 17381 17382 17383 17384 17385 17386 17387 17388 17389 17390 17391 17392 17393 17394 17395 17396 17397 17398 17399 17400 17401 17402 17403 17404 17405 17406 17407 17408 |
# File 'ext/cqpid/cqpid.cpp', line 17330
SWIGINTERN VALUE _wrap_Session_acknowledge(int nargs, VALUE *args, VALUE self) {
int argc;
VALUE argv[4];
int ii;
argc = nargs + 1;
argv[0] = self;
if (argc > 4) SWIG_fail;
for (ii = 1; (ii < argc); ++ii) {
argv[ii] = args[ii-1];
}
if (argc == 1) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_acknowledge__SWIG_1(nargs, args, self);
}
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_acknowledge__SWIG_3(nargs, args, self);
}
}
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
{
_v = (TYPE(argv[1]) == T_TRUE ||
TYPE(argv[1]) == T_FALSE) ? 1 : 0;
}
if (_v) {
return _wrap_Session_acknowledge__SWIG_0(nargs, args, self);
}
}
}
if (argc == 3) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0);
_v = SWIG_CheckState(res);
if (_v) {
{
_v = (TYPE(argv[2]) == T_TRUE ||
TYPE(argv[2]) == T_FALSE) ? 1 : 0;
}
if (_v) {
return _wrap_Session_acknowledge__SWIG_2(nargs, args, self);
}
}
}
}
fail:
Ruby_Format_OverloadedError( argc, 4, "Session.acknowledge",
" void Session.acknowledge(bool sync)\n"
" void Session.acknowledge()\n"
" void Session.acknowledge(qpid::messaging::Message &, bool sync)\n"
" void Session.acknowledge(qpid::messaging::Message &)\n");
return Qnil;
}
|
#acknowledgeUpTo(*args, self) ⇒ Object
17671 17672 17673 17674 17675 17676 17677 17678 17679 17680 17681 17682 17683 17684 17685 17686 17687 17688 17689 17690 17691 17692 17693 17694 17695 17696 17697 17698 17699 17700 17701 17702 17703 17704 17705 17706 17707 17708 17709 17710 17711 17712 17713 17714 17715 17716 17717 17718 17719 17720 17721 17722 17723 |
# File 'ext/cqpid/cqpid.cpp', line 17671
SWIGINTERN VALUE _wrap_Session_acknowledgeUpTo(int nargs, VALUE *args, VALUE self) {
int argc;
VALUE argv[4];
int ii;
argc = nargs + 1;
argv[0] = self;
if (argc > 4) SWIG_fail;
for (ii = 1; (ii < argc); ++ii) {
argv[ii] = args[ii-1];
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_acknowledgeUpTo__SWIG_1(nargs, args, self);
}
}
}
if (argc == 3) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0);
_v = SWIG_CheckState(res);
if (_v) {
{
_v = (TYPE(argv[2]) == T_TRUE ||
TYPE(argv[2]) == T_FALSE) ? 1 : 0;
}
if (_v) {
return _wrap_Session_acknowledgeUpTo__SWIG_0(nargs, args, self);
}
}
}
}
fail:
Ruby_Format_OverloadedError( argc, 4, "Session.acknowledgeUpTo",
" void Session.acknowledgeUpTo(qpid::messaging::Message &, bool sync)\n"
" void Session.acknowledgeUpTo(qpid::messaging::Message &)\n");
return Qnil;
}
|
#checkError(*args) ⇒ Object
20233 20234 20235 20236 20237 20238 20239 20240 20241 20242 20243 20244 20245 20246 20247 20248 20249 20250 20251 20252 20253 20254 20255 20256 20257 20258 20259 20260 20261 20262 20263 20264 20265 20266 20267 20268 20269 20270 20271 20272 20273 20274 20275 20276 20277 20278 20279 20280 20281 20282 20283 20284 20285 20286 20287 20288 20289 20290 20291 20292 20293 20294 20295 20296 20297 20298 20299 20300 20301 20302 20303 20304 20305 20306 20307 20308 20309 20310 20311 20312 20313 20314 20315 20316 20317 20318 20319 20320 20321 20322 20323 20324 20325 20326 20327 20328 20329 20330 20331 20332 20333 20334 20335 20336 20337 20338 20339 20340 20341 20342 20343 20344 20345 |
# File 'ext/cqpid/cqpid.cpp', line 20233
SWIGINTERN VALUE
_wrap_Session_checkError(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
if ((argc < 0) || (argc > 0)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","checkError", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
(arg1)->checkError();
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
return Qnil;
fail:
return Qnil;
}
|
#close(*args) ⇒ Object
16487 16488 16489 16490 16491 16492 16493 16494 16495 16496 16497 16498 16499 16500 16501 16502 16503 16504 16505 16506 16507 16508 16509 16510 16511 16512 16513 16514 16515 16516 16517 16518 16519 16520 16521 16522 16523 16524 16525 16526 16527 16528 16529 16530 16531 16532 16533 16534 16535 16536 16537 16538 16539 16540 16541 16542 16543 16544 16545 16546 16547 16548 16549 16550 16551 16552 16553 16554 16555 16556 16557 16558 16559 16560 16561 16562 16563 16564 16565 16566 16567 16568 16569 16570 16571 16572 16573 16574 16575 16576 16577 16578 16579 16580 16581 16582 16583 16584 16585 16586 16587 16588 16589 16590 16591 16592 16593 16594 16595 16596 16597 16598 16599 |
# File 'ext/cqpid/cqpid.cpp', line 16487
SWIGINTERN VALUE
_wrap_Session_close(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
if ((argc < 0) || (argc > 0)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","close", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
(arg1)->close();
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
return Qnil;
fail:
return Qnil;
}
|
#commit(*args) ⇒ Object
16602 16603 16604 16605 16606 16607 16608 16609 16610 16611 16612 16613 16614 16615 16616 16617 16618 16619 16620 16621 16622 16623 16624 16625 16626 16627 16628 16629 16630 16631 16632 16633 16634 16635 16636 16637 16638 16639 16640 16641 16642 16643 16644 16645 16646 16647 16648 16649 16650 16651 16652 16653 16654 16655 16656 16657 16658 16659 16660 16661 16662 16663 16664 16665 16666 16667 16668 16669 16670 16671 16672 16673 16674 16675 16676 16677 16678 16679 16680 16681 16682 16683 16684 16685 16686 16687 16688 16689 16690 16691 16692 16693 16694 16695 16696 16697 16698 16699 16700 16701 16702 16703 16704 16705 16706 16707 16708 16709 16710 16711 16712 16713 16714 |
# File 'ext/cqpid/cqpid.cpp', line 16602
SWIGINTERN VALUE
_wrap_Session_commit(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
if ((argc < 0) || (argc > 0)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","commit", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
(arg1)->commit();
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
return Qnil;
fail:
return Qnil;
}
|
#createReceiver(*args, self) ⇒ Object
19683 19684 19685 19686 19687 19688 19689 19690 19691 19692 19693 19694 19695 19696 19697 19698 19699 19700 19701 19702 19703 19704 19705 19706 19707 19708 19709 19710 19711 19712 19713 19714 19715 19716 19717 19718 19719 19720 19721 19722 19723 19724 19725 19726 19727 19728 |
# File 'ext/cqpid/cqpid.cpp', line 19683
SWIGINTERN VALUE _wrap_Session_createReceiver(int nargs, VALUE *args, VALUE self) {
int argc;
VALUE argv[3];
int ii;
argc = nargs + 1;
argv[0] = self;
if (argc > 3) SWIG_fail;
for (ii = 1; (ii < argc); ++ii) {
argv[ii] = args[ii-1];
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Address, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_createReceiver__SWIG_0(nargs, args, self);
}
}
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
int res = SWIG_AsPtr_std_string(argv[1], (std::string**)(0));
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_createReceiver__SWIG_1(nargs, args, self);
}
}
}
fail:
Ruby_Format_OverloadedError( argc, 3, "Session.createReceiver",
" qpid::messaging::Receiver Session.createReceiver(qpid::messaging::Address const &address)\n"
" qpid::messaging::Receiver Session.createReceiver(std::string const &address)\n");
return Qnil;
}
|
#createSender(*args, self) ⇒ Object
19373 19374 19375 19376 19377 19378 19379 19380 19381 19382 19383 19384 19385 19386 19387 19388 19389 19390 19391 19392 19393 19394 19395 19396 19397 19398 19399 19400 19401 19402 19403 19404 19405 19406 19407 19408 19409 19410 19411 19412 19413 19414 19415 19416 19417 19418 |
# File 'ext/cqpid/cqpid.cpp', line 19373
SWIGINTERN VALUE _wrap_Session_createSender(int nargs, VALUE *args, VALUE self) {
int argc;
VALUE argv[3];
int ii;
argc = nargs + 1;
argv[0] = self;
if (argc > 3) SWIG_fail;
for (ii = 1; (ii < argc); ++ii) {
argv[ii] = args[ii-1];
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Address, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_createSender__SWIG_0(nargs, args, self);
}
}
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
int res = SWIG_AsPtr_std_string(argv[1], (std::string**)(0));
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_createSender__SWIG_1(nargs, args, self);
}
}
}
fail:
Ruby_Format_OverloadedError( argc, 3, "Session.createSender",
" qpid::messaging::Sender Session.createSender(qpid::messaging::Address const &address)\n"
" qpid::messaging::Sender Session.createSender(std::string const &address)\n");
return Qnil;
}
|
#getConnection(*args) ⇒ Object
19997 19998 19999 20000 20001 20002 20003 20004 20005 20006 20007 20008 20009 20010 20011 20012 20013 20014 20015 20016 20017 20018 20019 20020 20021 20022 20023 20024 20025 20026 20027 20028 20029 20030 20031 20032 20033 20034 20035 20036 20037 20038 20039 20040 20041 20042 20043 20044 20045 20046 20047 20048 20049 20050 20051 20052 20053 20054 20055 20056 20057 20058 20059 20060 20061 20062 20063 20064 20065 20066 20067 20068 20069 20070 20071 20072 20073 20074 20075 20076 20077 20078 20079 20080 20081 20082 20083 20084 20085 20086 20087 20088 20089 20090 20091 20092 20093 20094 20095 20096 20097 20098 20099 20100 20101 20102 20103 20104 20105 20106 20107 20108 20109 20110 20111 20112 |
# File 'ext/cqpid/cqpid.cpp', line 19997
SWIGINTERN VALUE
_wrap_Session_getConnection(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
qpid::messaging::Connection result;
VALUE vresult = Qnil;
if ((argc < 0) || (argc > 0)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session const *","getConnection", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
result = ((qpid::messaging::Session const *)arg1)->getConnection();
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
vresult = SWIG_NewPointerObj((new qpid::messaging::Connection(static_cast< const qpid::messaging::Connection& >(result))), SWIGTYPE_p_qpid__messaging__Connection, SWIG_POINTER_OWN | 0 );
return vresult;
fail:
return Qnil;
}
|
#getReceivable(*args) ⇒ Object
18270 18271 18272 18273 18274 18275 18276 18277 18278 18279 18280 18281 18282 18283 18284 18285 18286 18287 18288 18289 18290 18291 18292 18293 18294 18295 18296 18297 18298 18299 18300 18301 18302 18303 18304 18305 18306 18307 18308 18309 18310 18311 18312 18313 18314 18315 18316 18317 18318 18319 18320 18321 18322 18323 18324 18325 18326 18327 18328 18329 18330 18331 18332 18333 18334 18335 18336 18337 18338 18339 18340 18341 18342 18343 18344 18345 18346 18347 18348 18349 18350 18351 18352 18353 18354 18355 18356 18357 18358 18359 18360 18361 18362 18363 18364 18365 18366 18367 18368 18369 18370 18371 18372 18373 18374 18375 18376 18377 18378 18379 18380 18381 18382 18383 18384 18385 18386 18387 |
# File 'ext/cqpid/cqpid.cpp', line 18270
SWIGINTERN VALUE
_wrap_Session_getReceivable(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
uint32_t result;
VALUE vresult = Qnil;
if ((argc < 0) || (argc > 0)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","getReceivable", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
result = (arg1)->getReceivable();
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
{
vresult = UINT2NUM((uint32_t) result);
}
return vresult;
fail:
return Qnil;
}
|
#getReceiver(*args) ⇒ Object
19864 19865 19866 19867 19868 19869 19870 19871 19872 19873 19874 19875 19876 19877 19878 19879 19880 19881 19882 19883 19884 19885 19886 19887 19888 19889 19890 19891 19892 19893 19894 19895 19896 19897 19898 19899 19900 19901 19902 19903 19904 19905 19906 19907 19908 19909 19910 19911 19912 19913 19914 19915 19916 19917 19918 19919 19920 19921 19922 19923 19924 19925 19926 19927 19928 19929 19930 19931 19932 19933 19934 19935 19936 19937 19938 19939 19940 19941 19942 19943 19944 19945 19946 19947 19948 19949 19950 19951 19952 19953 19954 19955 19956 19957 19958 19959 19960 19961 19962 19963 19964 19965 19966 19967 19968 19969 19970 19971 19972 19973 19974 19975 19976 19977 19978 19979 19980 19981 19982 19983 19984 19985 19986 19987 19988 19989 19990 19991 19992 19993 19994 |
# File 'ext/cqpid/cqpid.cpp', line 19864
SWIGINTERN VALUE
_wrap_Session_getReceiver(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
std::string *arg2 = 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
int res2 = SWIG_OLDOBJ ;
qpid::messaging::Receiver result;
VALUE vresult = Qnil;
if ((argc < 1) || (argc > 1)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session const *","getReceiver", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
std::string *ptr = (std::string *)0;
res2 = SWIG_AsPtr_std_string(argv[0], &ptr);
if (!SWIG_IsOK(res2)) {
SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "std::string const &","getReceiver", 2, argv[0] ));
}
if (!ptr) {
SWIG_exception_fail(SWIG_ValueError, Ruby_Format_TypeError("invalid null reference ", "std::string const &","getReceiver", 2, argv[0]));
}
arg2 = ptr;
}
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
result = ((qpid::messaging::Session const *)arg1)->getReceiver((std::string const &)*arg2);
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
vresult = SWIG_NewPointerObj((new qpid::messaging::Receiver(static_cast< const qpid::messaging::Receiver& >(result))), SWIGTYPE_p_qpid__messaging__Receiver, SWIG_POINTER_OWN | 0 );
if (SWIG_IsNewObj(res2)) delete arg2;
return vresult;
fail:
if (SWIG_IsNewObj(res2)) delete arg2;
return Qnil;
}
|
#getSender(*args) ⇒ Object
19731 19732 19733 19734 19735 19736 19737 19738 19739 19740 19741 19742 19743 19744 19745 19746 19747 19748 19749 19750 19751 19752 19753 19754 19755 19756 19757 19758 19759 19760 19761 19762 19763 19764 19765 19766 19767 19768 19769 19770 19771 19772 19773 19774 19775 19776 19777 19778 19779 19780 19781 19782 19783 19784 19785 19786 19787 19788 19789 19790 19791 19792 19793 19794 19795 19796 19797 19798 19799 19800 19801 19802 19803 19804 19805 19806 19807 19808 19809 19810 19811 19812 19813 19814 19815 19816 19817 19818 19819 19820 19821 19822 19823 19824 19825 19826 19827 19828 19829 19830 19831 19832 19833 19834 19835 19836 19837 19838 19839 19840 19841 19842 19843 19844 19845 19846 19847 19848 19849 19850 19851 19852 19853 19854 19855 19856 19857 19858 19859 19860 19861 |
# File 'ext/cqpid/cqpid.cpp', line 19731
SWIGINTERN VALUE
_wrap_Session_getSender(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
std::string *arg2 = 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
int res2 = SWIG_OLDOBJ ;
qpid::messaging::Sender result;
VALUE vresult = Qnil;
if ((argc < 1) || (argc > 1)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session const *","getSender", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
std::string *ptr = (std::string *)0;
res2 = SWIG_AsPtr_std_string(argv[0], &ptr);
if (!SWIG_IsOK(res2)) {
SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "std::string const &","getSender", 2, argv[0] ));
}
if (!ptr) {
SWIG_exception_fail(SWIG_ValueError, Ruby_Format_TypeError("invalid null reference ", "std::string const &","getSender", 2, argv[0]));
}
arg2 = ptr;
}
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
result = ((qpid::messaging::Session const *)arg1)->getSender((std::string const &)*arg2);
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
vresult = SWIG_NewPointerObj((new qpid::messaging::Sender(static_cast< const qpid::messaging::Sender& >(result))), SWIGTYPE_p_qpid__messaging__Sender, SWIG_POINTER_OWN | 0 );
if (SWIG_IsNewObj(res2)) delete arg2;
return vresult;
fail:
if (SWIG_IsNewObj(res2)) delete arg2;
return Qnil;
}
|
#getUnsettledAcks(*args) ⇒ Object
18390 18391 18392 18393 18394 18395 18396 18397 18398 18399 18400 18401 18402 18403 18404 18405 18406 18407 18408 18409 18410 18411 18412 18413 18414 18415 18416 18417 18418 18419 18420 18421 18422 18423 18424 18425 18426 18427 18428 18429 18430 18431 18432 18433 18434 18435 18436 18437 18438 18439 18440 18441 18442 18443 18444 18445 18446 18447 18448 18449 18450 18451 18452 18453 18454 18455 18456 18457 18458 18459 18460 18461 18462 18463 18464 18465 18466 18467 18468 18469 18470 18471 18472 18473 18474 18475 18476 18477 18478 18479 18480 18481 18482 18483 18484 18485 18486 18487 18488 18489 18490 18491 18492 18493 18494 18495 18496 18497 18498 18499 18500 18501 18502 18503 18504 18505 18506 18507 |
# File 'ext/cqpid/cqpid.cpp', line 18390
SWIGINTERN VALUE
_wrap_Session_getUnsettledAcks(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
uint32_t result;
VALUE vresult = Qnil;
if ((argc < 0) || (argc > 0)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","getUnsettledAcks", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
result = (arg1)->getUnsettledAcks();
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
{
vresult = UINT2NUM((uint32_t) result);
}
return vresult;
fail:
return Qnil;
}
|
#hasError(*args) ⇒ Object
20115 20116 20117 20118 20119 20120 20121 20122 20123 20124 20125 20126 20127 20128 20129 20130 20131 20132 20133 20134 20135 20136 20137 20138 20139 20140 20141 20142 20143 20144 20145 20146 20147 20148 20149 20150 20151 20152 20153 20154 20155 20156 20157 20158 20159 20160 20161 20162 20163 20164 20165 20166 20167 20168 20169 20170 20171 20172 20173 20174 20175 20176 20177 20178 20179 20180 20181 20182 20183 20184 20185 20186 20187 20188 20189 20190 20191 20192 20193 20194 20195 20196 20197 20198 20199 20200 20201 20202 20203 20204 20205 20206 20207 20208 20209 20210 20211 20212 20213 20214 20215 20216 20217 20218 20219 20220 20221 20222 20223 20224 20225 20226 20227 20228 20229 20230 |
# File 'ext/cqpid/cqpid.cpp', line 20115
SWIGINTERN VALUE
_wrap_Session_hasError(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
bool result;
VALUE vresult = Qnil;
if ((argc < 0) || (argc > 0)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","hasError", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
result = (bool)(arg1)->hasError();
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
vresult = SWIG_From_bool(static_cast< bool >(result));
return vresult;
fail:
return Qnil;
}
|
#nextReceiver(*args, self) ⇒ Object
19032 19033 19034 19035 19036 19037 19038 19039 19040 19041 19042 19043 19044 19045 19046 19047 19048 19049 19050 19051 19052 19053 19054 19055 19056 19057 19058 19059 19060 19061 19062 19063 19064 19065 19066 19067 19068 19069 19070 19071 19072 19073 19074 19075 19076 19077 19078 19079 19080 19081 19082 19083 19084 19085 19086 19087 19088 19089 19090 19091 19092 19093 19094 19095 19096 19097 19098 19099 19100 19101 19102 19103 19104 19105 19106 19107 19108 |
# File 'ext/cqpid/cqpid.cpp', line 19032
SWIGINTERN VALUE _wrap_Session_nextReceiver(int nargs, VALUE *args, VALUE self) {
int argc;
VALUE argv[4];
int ii;
argc = nargs + 1;
argv[0] = self;
if (argc > 4) SWIG_fail;
for (ii = 1; (ii < argc); ++ii) {
argv[ii] = args[ii-1];
}
if (argc == 1) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_nextReceiver__SWIG_3(nargs, args, self);
}
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Duration, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_nextReceiver__SWIG_2(nargs, args, self);
}
}
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Receiver, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_nextReceiver__SWIG_1(nargs, args, self);
}
}
}
if (argc == 3) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Receiver, 0);
_v = SWIG_CheckState(res);
if (_v) {
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[2], &vptr, SWIGTYPE_p_qpid__messaging__Duration, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_nextReceiver__SWIG_0(nargs, args, self);
}
}
}
}
fail:
Ruby_Format_OverloadedError( argc, 4, "Session.nextReceiver",
" bool Session.nextReceiver(qpid::messaging::Receiver &, qpid::messaging::Duration timeout)\n"
" bool Session.nextReceiver(qpid::messaging::Receiver &)\n"
" qpid::messaging::Receiver Session.nextReceiver(qpid::messaging::Duration timeout)\n"
" qpid::messaging::Receiver Session.nextReceiver()\n");
return Qnil;
}
|
#reject(*args) ⇒ Object
call-seq:
reject(arg2)
Iterate thru each element in the Session and reject those that fail a condition returning a new Session. A block must be provided.
17735 17736 17737 17738 17739 17740 17741 17742 17743 17744 17745 17746 17747 17748 17749 17750 17751 17752 17753 17754 17755 17756 17757 17758 17759 17760 17761 17762 17763 17764 17765 17766 17767 17768 17769 17770 17771 17772 17773 17774 17775 17776 17777 17778 17779 17780 17781 17782 17783 17784 17785 17786 17787 17788 17789 17790 17791 17792 17793 17794 17795 17796 17797 17798 17799 17800 17801 17802 17803 17804 17805 17806 17807 17808 17809 17810 17811 17812 17813 17814 17815 17816 17817 17818 17819 17820 17821 17822 17823 17824 17825 17826 17827 17828 17829 17830 17831 17832 17833 17834 17835 17836 17837 17838 17839 17840 17841 17842 17843 17844 17845 17846 17847 17848 17849 17850 17851 17852 17853 17854 17855 17856 17857 17858 |
# File 'ext/cqpid/cqpid.cpp', line 17735
SWIGINTERN VALUE
_wrap_Session_reject(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
qpid::messaging::Message *arg2 = 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
void *argp2 = 0 ;
int res2 = 0 ;
if ((argc < 1) || (argc > 1)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","reject", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
res2 = SWIG_ConvertPtr(argv[0], &argp2, SWIGTYPE_p_qpid__messaging__Message, 0 );
if (!SWIG_IsOK(res2)) {
SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "qpid::messaging::Message &","reject", 2, argv[0] ));
}
if (!argp2) {
SWIG_exception_fail(SWIG_ValueError, Ruby_Format_TypeError("invalid null reference ", "qpid::messaging::Message &","reject", 2, argv[0]));
}
arg2 = reinterpret_cast< qpid::messaging::Message * >(argp2);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
(arg1)->reject(*arg2);
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
return Qnil;
fail:
return Qnil;
}
|
#release(*args) ⇒ Object
17861 17862 17863 17864 17865 17866 17867 17868 17869 17870 17871 17872 17873 17874 17875 17876 17877 17878 17879 17880 17881 17882 17883 17884 17885 17886 17887 17888 17889 17890 17891 17892 17893 17894 17895 17896 17897 17898 17899 17900 17901 17902 17903 17904 17905 17906 17907 17908 17909 17910 17911 17912 17913 17914 17915 17916 17917 17918 17919 17920 17921 17922 17923 17924 17925 17926 17927 17928 17929 17930 17931 17932 17933 17934 17935 17936 17937 17938 17939 17940 17941 17942 17943 17944 17945 17946 17947 17948 17949 17950 17951 17952 17953 17954 17955 17956 17957 17958 17959 17960 17961 17962 17963 17964 17965 17966 17967 17968 17969 17970 17971 17972 17973 17974 17975 17976 17977 17978 17979 17980 17981 17982 17983 17984 |
# File 'ext/cqpid/cqpid.cpp', line 17861
SWIGINTERN VALUE
_wrap_Session_release(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
qpid::messaging::Message *arg2 = 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
void *argp2 = 0 ;
int res2 = 0 ;
if ((argc < 1) || (argc > 1)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","release", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
res2 = SWIG_ConvertPtr(argv[0], &argp2, SWIGTYPE_p_qpid__messaging__Message, 0 );
if (!SWIG_IsOK(res2)) {
SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "qpid::messaging::Message &","release", 2, argv[0] ));
}
if (!argp2) {
SWIG_exception_fail(SWIG_ValueError, Ruby_Format_TypeError("invalid null reference ", "qpid::messaging::Message &","release", 2, argv[0]));
}
arg2 = reinterpret_cast< qpid::messaging::Message * >(argp2);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
(arg1)->release(*arg2);
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
return Qnil;
fail:
return Qnil;
}
|
#rollback(*args) ⇒ Object
16717 16718 16719 16720 16721 16722 16723 16724 16725 16726 16727 16728 16729 16730 16731 16732 16733 16734 16735 16736 16737 16738 16739 16740 16741 16742 16743 16744 16745 16746 16747 16748 16749 16750 16751 16752 16753 16754 16755 16756 16757 16758 16759 16760 16761 16762 16763 16764 16765 16766 16767 16768 16769 16770 16771 16772 16773 16774 16775 16776 16777 16778 16779 16780 16781 16782 16783 16784 16785 16786 16787 16788 16789 16790 16791 16792 16793 16794 16795 16796 16797 16798 16799 16800 16801 16802 16803 16804 16805 16806 16807 16808 16809 16810 16811 16812 16813 16814 16815 16816 16817 16818 16819 16820 16821 16822 16823 16824 16825 16826 16827 16828 16829 |
# File 'ext/cqpid/cqpid.cpp', line 16717
SWIGINTERN VALUE
_wrap_Session_rollback(int argc, VALUE *argv, VALUE self) {
qpid::messaging::Session *arg1 = (qpid::messaging::Session *) 0 ;
void *argp1 = 0 ;
int res1 = 0 ;
if ((argc < 0) || (argc > 0)) {
rb_raise(rb_eArgError, "wrong # of arguments(%d for 0)",argc); SWIG_fail;
}
res1 = SWIG_ConvertPtr(self, &argp1,SWIGTYPE_p_qpid__messaging__Session, 0 | 0 );
if (!SWIG_IsOK(res1)) {
SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Session *","rollback", 1, self ));
}
arg1 = reinterpret_cast< qpid::messaging::Session * >(argp1);
{
static VALUE eMessagingError = rb_define_class("MessagingError",
rb_eStandardError);
try {
(arg1)->rollback();
}
catch(qpid::messaging::ConnectionError& error) {
static VALUE merror = rb_define_class("ConnectionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransportFailure& error) {
static VALUE merror = rb_define_class("TransportFailure", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionAborted& error) {
static VALUE merror = rb_define_class("TransactionAborted", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionUnknown& error) {
static VALUE merror = rb_define_class("TransactionUnknown", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TransactionError& error) {
static VALUE merror = rb_define_class("TransactionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::UnauthorizedAccess& error) {
static VALUE merror = rb_define_class("UnauthorizedAccess", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SessionError& error) {
static VALUE merror = rb_define_class("SessionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::TargetCapacityExceeded& error) {
static VALUE merror = rb_define_class("TargetCapacityExceeded", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SendError& error) {
static VALUE merror = rb_define_class("SendError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::SenderError& error) {
static VALUE merror = rb_define_class("SenderError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NoMessageAvailable& error) {
static VALUE merror = rb_define_class("NoMessageAvailable", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::FetchError& error) {
static VALUE merror = rb_define_class("FetchError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ReceiverError& error) {
static VALUE merror = rb_define_class("ReceiverError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::InvalidOptionString& error) {
static VALUE merror = rb_define_class("InvalidOptionString", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::KeyError& error) {
static VALUE merror = rb_define_class("KeyError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AssertionFailed& error) {
static VALUE merror = rb_define_class("AssertionFailed", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::NotFound& error) {
static VALUE merror = rb_define_class("NotFound", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::ResolutionError& error) {
static VALUE merror = rb_define_class("ResolutionError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MalformedAddress& error) {
static VALUE merror = rb_define_class("MalformedAddress", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::AddressError& error) {
static VALUE merror = rb_define_class("AddressError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::LinkError& error) {
static VALUE merror = rb_define_class("LinkError", eMessagingError);
rb_raise(merror, "%s", error.what());
}
catch(qpid::messaging::MessagingException& error) {
rb_raise(eMessagingError, "%s", error.what());
}
}
return Qnil;
fail:
return Qnil;
}
|
#sync(*args, self) ⇒ Object
18225 18226 18227 18228 18229 18230 18231 18232 18233 18234 18235 18236 18237 18238 18239 18240 18241 18242 18243 18244 18245 18246 18247 18248 18249 18250 18251 18252 18253 18254 18255 18256 18257 18258 18259 18260 18261 18262 18263 18264 18265 18266 18267 |
# File 'ext/cqpid/cqpid.cpp', line 18225
SWIGINTERN VALUE _wrap_Session_sync(int nargs, VALUE *args, VALUE self) {
int argc;
VALUE argv[3];
int ii;
argc = nargs + 1;
argv[0] = self;
if (argc > 3) SWIG_fail;
for (ii = 1; (ii < argc); ++ii) {
argv[ii] = args[ii-1];
}
if (argc == 1) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
return _wrap_Session_sync__SWIG_1(nargs, args, self);
}
}
if (argc == 2) {
int _v;
void *vptr = 0;
int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Session, 0);
_v = SWIG_CheckState(res);
if (_v) {
{
_v = (TYPE(argv[1]) == T_TRUE ||
TYPE(argv[1]) == T_FALSE) ? 1 : 0;
}
if (_v) {
return _wrap_Session_sync__SWIG_0(nargs, args, self);
}
}
}
fail:
Ruby_Format_OverloadedError( argc, 3, "Session.sync",
" void Session.sync(bool block)\n"
" void Session.sync()\n");
return Qnil;
}
|