module Cqpid
register a new class
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;
}