AnyMQ-AMQP

 view release on metacpan or  search on metacpan

lib/AnyMQ/Trait/AMQP.pm  view on Meta::CPAN

20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
has _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 )