module Cqpid
Constants
- Critical
- Debug
- Error
- Info
- Notice
- Trace
- Warning
Public Class Methods
*(*args)
click to toggle source
SWIGINTERN VALUE _wrap___mul__(int nargs, VALUE *args, VALUE self) { int argc; VALUE argv[2]; int ii; argc = nargs; if (argc > 2) SWIG_fail; for (ii = 0; (ii < argc); ++ii) { argv[ii] = args[ii]; } if (argc == 2) { int _v; void *vptr = 0; int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Duration, 0); _v = SWIG_CheckState(res); if (_v) { { _v = FIXNUM_P(argv[1]); } if (_v) { return _wrap___mul____SWIG_0(nargs, args, self); } } } if (argc == 2) { int _v; { _v = FIXNUM_P(argv[0]); } 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___mul____SWIG_1(nargs, args, self); } } } fail: Ruby_Format_OverloadedError( argc, 2, "__mul__", " qpid::messaging::Duration __mul__(qpid::messaging::Duration const &duration, uint64_t multiplier)\n" " qpid::messaging::Duration __mul__(uint64_t multiplier, qpid::messaging::Duration const &duration)\n"); return Qnil; }
==(a, b) → bool
click to toggle source
Equality comparison operator.
SWIGINTERN VALUE _wrap___eq__(int argc, VALUE *argv, VALUE self) { qpid::messaging::Duration *arg1 = 0 ; qpid::messaging::Duration *arg2 = 0 ; void *argp1 ; int res1 = 0 ; void *argp2 ; int res2 = 0 ; bool result; VALUE vresult = Qnil; if ((argc < 2) || (argc > 2)) { rb_raise(rb_eArgError, "wrong # of arguments(%d for 2)",argc); SWIG_fail; } res1 = SWIG_ConvertPtr(argv[0], &argp1, SWIGTYPE_p_qpid__messaging__Duration, 0 ); if (!SWIG_IsOK(res1)) { SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Duration const &","qpid::messaging::operator ==", 1, argv[0] )); } if (!argp1) { SWIG_exception_fail(SWIG_ValueError, Ruby_Format_TypeError("invalid null reference ", "qpid::messaging::Duration const &","qpid::messaging::operator ==", 1, argv[0])); } arg1 = reinterpret_cast< qpid::messaging::Duration * >(argp1); res2 = SWIG_ConvertPtr(argv[1], &argp2, SWIGTYPE_p_qpid__messaging__Duration, 0 ); if (!SWIG_IsOK(res2)) { SWIG_exception_fail(SWIG_ArgError(res2), Ruby_Format_TypeError( "", "qpid::messaging::Duration const &","qpid::messaging::operator ==", 2, argv[1] )); } if (!argp2) { SWIG_exception_fail(SWIG_ValueError, Ruby_Format_TypeError("invalid null reference ", "qpid::messaging::Duration const &","qpid::messaging::operator ==", 2, argv[1])); } arg2 = reinterpret_cast< qpid::messaging::Duration * >(argp2); { static VALUE eMessagingError = rb_define_class("MessagingError", rb_eStandardError); try { result = (bool)qpid::messaging::operator ==((qpid::messaging::Duration const &)*arg1,(qpid::messaging::Duration 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_From_bool(static_cast< bool >(result)); return vresult; fail: return Qnil; }
decode(*args)
click to toggle source
SWIGINTERN VALUE _wrap_decode(int nargs, VALUE *args, VALUE self) { int argc; VALUE argv[3]; int ii; argc = nargs; if (argc > 3) SWIG_fail; for (ii = 0; (ii < argc); ++ii) { argv[ii] = args[ii]; } if (argc == 2) { int _v; void *vptr = 0; int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0); _v = SWIG_CheckState(res); if (_v) { { _v = (TYPE(argv[1]) == T_HASH) ? 1 : 0; } if (_v) { return _wrap_decode__SWIG_1(nargs, args, self); } } } if (argc == 2) { int _v; void *vptr = 0; int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0); _v = SWIG_CheckState(res); if (_v) { { _v = (TYPE(argv[1]) == T_ARRAY) ? 1 : 0; } if (_v) { return _wrap_decode__SWIG_3(nargs, args, self); } } } if (argc == 3) { int _v; void *vptr = 0; int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0); _v = SWIG_CheckState(res); if (_v) { { _v = (TYPE(argv[1]) == T_ARRAY) ? 1 : 0; } if (_v) { int res = SWIG_AsPtr_std_string(argv[2], (std::string**)(0)); _v = SWIG_CheckState(res); if (_v) { return _wrap_decode__SWIG_2(nargs, args, self); } } } } if (argc == 3) { int _v; void *vptr = 0; int res = SWIG_ConvertPtr(argv[0], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0); _v = SWIG_CheckState(res); if (_v) { { _v = (TYPE(argv[1]) == T_HASH) ? 1 : 0; } if (_v) { int res = SWIG_AsPtr_std_string(argv[2], (std::string**)(0)); _v = SWIG_CheckState(res); if (_v) { return _wrap_decode__SWIG_0(nargs, args, self); } } } } fail: Ruby_Format_OverloadedError( argc, 3, "decode", " void decode(qpid::messaging::Message const &message, qpid::types::Variant::Map &map, std::string const &encoding)\n" " void decode(qpid::messaging::Message const &message, qpid::types::Variant::Map &map)\n" " void decode(qpid::messaging::Message const &message, qpid::types::Variant::List &list, std::string const &encoding)\n" " void decode(qpid::messaging::Message const &message, qpid::types::Variant::List &list)\n"); return Qnil; }
decodeList(*args)
click to toggle source
SWIGINTERN VALUE _wrap_decodeList(int argc, VALUE *argv, VALUE self) { qpid::messaging::Message *arg1 = 0 ; void *argp1 ; int res1 = 0 ; qpid::types::Variant::List *result = 0 ; VALUE vresult = Qnil; if ((argc < 1) || (argc > 1)) { rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; } res1 = SWIG_ConvertPtr(argv[0], &argp1, SWIGTYPE_p_qpid__messaging__Message, 0 ); if (!SWIG_IsOK(res1)) { SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Message const &","decodeList", 1, argv[0] )); } if (!argp1) { SWIG_exception_fail(SWIG_ValueError, Ruby_Format_TypeError("invalid null reference ", "qpid::messaging::Message const &","decodeList", 1, argv[0])); } arg1 = reinterpret_cast< qpid::messaging::Message * >(argp1); { static VALUE eMessagingError = rb_define_class("MessagingError", rb_eStandardError); try { result = (qpid::types::Variant::List *) &decodeList((qpid::messaging::Message const &)*arg1); } 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 = ListToRb(result); } return vresult; fail: return Qnil; }
decodeMap(*args)
click to toggle source
SWIGINTERN VALUE _wrap_decodeMap(int argc, VALUE *argv, VALUE self) { qpid::messaging::Message *arg1 = 0 ; void *argp1 ; int res1 = 0 ; qpid::types::Variant::Map *result = 0 ; VALUE vresult = Qnil; if ((argc < 1) || (argc > 1)) { rb_raise(rb_eArgError, "wrong # of arguments(%d for 1)",argc); SWIG_fail; } res1 = SWIG_ConvertPtr(argv[0], &argp1, SWIGTYPE_p_qpid__messaging__Message, 0 ); if (!SWIG_IsOK(res1)) { SWIG_exception_fail(SWIG_ArgError(res1), Ruby_Format_TypeError( "", "qpid::messaging::Message const &","decodeMap", 1, argv[0] )); } if (!argp1) { SWIG_exception_fail(SWIG_ValueError, Ruby_Format_TypeError("invalid null reference ", "qpid::messaging::Message const &","decodeMap", 1, argv[0])); } arg1 = reinterpret_cast< qpid::messaging::Message * >(argp1); { static VALUE eMessagingError = rb_define_class("MessagingError", rb_eStandardError); try { result = (qpid::types::Variant::Map *) &decodeMap((qpid::messaging::Message const &)*arg1); } 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 = MapToRb(result); } return vresult; fail: return Qnil; }
encode(*args)
click to toggle source
SWIGINTERN VALUE _wrap_encode(int nargs, VALUE *args, VALUE self) { int argc; VALUE argv[3]; int ii; argc = nargs; if (argc > 3) SWIG_fail; for (ii = 0; (ii < argc); ++ii) { argv[ii] = args[ii]; } if (argc == 2) { int _v; { _v = (TYPE(argv[0]) == T_HASH) ? 1 : 0; } 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_encode__SWIG_1(nargs, args, self); } } } if (argc == 2) { int _v; { _v = (TYPE(argv[0]) == T_ARRAY) ? 1 : 0; } 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_encode__SWIG_3(nargs, args, self); } } } if (argc == 3) { int _v; { _v = (TYPE(argv[0]) == T_ARRAY) ? 1 : 0; } if (_v) { void *vptr = 0; int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0); _v = SWIG_CheckState(res); if (_v) { int res = SWIG_AsPtr_std_string(argv[2], (std::string**)(0)); _v = SWIG_CheckState(res); if (_v) { return _wrap_encode__SWIG_2(nargs, args, self); } } } } if (argc == 3) { int _v; { _v = (TYPE(argv[0]) == T_HASH) ? 1 : 0; } if (_v) { void *vptr = 0; int res = SWIG_ConvertPtr(argv[1], &vptr, SWIGTYPE_p_qpid__messaging__Message, 0); _v = SWIG_CheckState(res); if (_v) { int res = SWIG_AsPtr_std_string(argv[2], (std::string**)(0)); _v = SWIG_CheckState(res); if (_v) { return _wrap_encode__SWIG_0(nargs, args, self); } } } } fail: Ruby_Format_OverloadedError( argc, 3, "encode", " void encode(qpid::types::Variant::Map const &map, qpid::messaging::Message &message, std::string const &encoding)\n" " void encode(qpid::types::Variant::Map const &map, qpid::messaging::Message &message)\n" " void encode(qpid::types::Variant::List const &list, qpid::messaging::Message &message, std::string const &encoding)\n" " void encode(qpid::types::Variant::List const &list, qpid::messaging::Message &message)\n"); return Qnil; }