AnyMQ-AMQP
view release on metacpan or search on metacpan
lib/AnyMQ/Trait/AMQP.pm view on Meta::CPAN
202122232425262728293031323334353637383940has
_rf
=> (
is
=>
"rw"
);
has
_rf_channel
=> (
is
=>
"rw"
);
has
_rf_queue
=> (
is
=>
"rw"
);
has
cv
=> (
is
=>
"rw"
,
isa
=>
"AnyEvent::CondVar"
);
has
on_ready
=> (
is
=>
"rw"
,
isa
=>
"CodeRef"
);
has
_connected
=> (
is
=>
"rw"
,
isa
=>
"Bool"
);
sub
default_amqp_spec {
#this is to avoid loading coro
my
$dir
= File::ShareDir::dist_dir(
"AnyEvent-RabbitMQ"
);
return
"$dir/fixed_amqp0-8.xml"
;
}
AnyEvent::RabbitMQ->load_xml_spec(default_amqp_spec());
sub
BUILD {};
after
'BUILD'
=>
sub
{
my
$self
=
shift
;
my
$cv
=
$self
->cv(AE::cv);
( run in 0.288 second using v1.01-cache-2.11-cpan-1dc43b0fbd2 )