AnyEvent-RabbitMQ-Fork

 view release on metacpan or  search on metacpan

Changes  view on Meta::CPAN

0.6       2020-07-26 14:02:30-04:00 America/New_York
    - fix operator typo in _generate_callback
    - redundant code cleanup
    - simplify logic in _generate_callback
    - make ::Channel->delegate private
    - safer rpc callbacks with weakened self
    - update test suite from AnyEent::RabbitMQ with mods to get it working again

0.5       2014-12-28 17:38:10-05:00 America/New_York
    - update test suite to align with AnyEvent::RabbitMQ
    - support bind_exchange & unbind_exchange methods
    - in Worker: generate stand-in callbacks in a separate method

0.4       2014-06-06 16:43:00-04:00 America/New_York
    - improve handling object state attirbutes being reported to parent

0.3       2014-06-05 08:49:21-04:00 America/New_York
    - be less dynamic about building sub-class strings; no need to be fancy
    - adhere closer to AnyEvent::RabbitMQ::Channel structure

    (back fill changelog entries)

lib/AnyEvent/RabbitMQ/Fork/Channel.pm  view on Meta::CPAN

=head1 METHODS

Pretty well enumerated in L<AnyEvent::RabbitMQ::Channel>.

=cut

my @methods = qw(
  open
  close
  declare_exchange
  bind_exchange
  unbind_exchange
  delete_exchange
  declare_queue
  bind_queue
  unbind_queue
  purge_queue
  delete_queue
  publish
  consume
  cancel
  get
  ack
  qos
  confirm
  recover

t/release-04_anyevent.t  view on Meta::CPAN

    exchange   => 'test_x_dest',
    on_success => sub {
        pass('declare destination exchange');
        $done->send;
    },
    on_failure => failure_cb($done),
);
$done->recv;

$done = AnyEvent->condvar;
$ch->bind_exchange(
    source      => 'test_x',
    destination => 'test_x_dest',
    on_success  => sub {
        pass('bind exchange -> dest');
        $done->send;
    },
    on_failure => failure_cb($done),
);
$done->recv;

$done = AnyEvent->condvar;
$ch->declare_queue(
    queue      => 'test_q',
    on_success => sub {
        pass('declare queue');
        $done->send;
    },
    on_failure => failure_cb($done),
);
$done->recv;

$done = AnyEvent->condvar;
$ch->bind_queue(
    queue       => 'test_q',
    exchange    => 'test_x',
    routing_key => 'test_r',
    on_success  => sub {
        pass('bound queue');
        $done->send;
    },
    on_failure => failure_cb($done),
);
$done->recv;

t/release-04_anyevent.t  view on Meta::CPAN

    queue      => 'test_q',
    on_success => sub {
        pass('purge queue');
        $done->send;
    },
    on_failure => failure_cb($done),
);
$done->recv;

$done = AnyEvent->condvar;
$ch->unbind_queue(
    queue       => 'test_q',
    exchange    => 'test_x',
    routing_key => 'test_r',
    on_success  => sub {
        pass('unbind queue');
        $done->send;
    },
    on_failure => failure_cb($done),
);
$done->recv;

$done = AnyEvent->condvar;
$ch->delete_queue(
    queue      => 'test_q',
    on_success => sub {
        pass('delete queue');
        $done->send;
    },
    on_failure => failure_cb($done),
);
$done->recv;

$done = AnyEvent->condvar;
$ch->unbind_exchange(
    source      => 'test_x',
    destination => 'test_x_dest',
    on_success  => sub {
        pass('unbind exchange');
        $done->send;
    },
    on_failure => failure_cb($done),
);
$done->recv;

$done = AnyEvent->condvar;
$ch->delete_exchange(
    exchange   => 'test_x',
    on_success => sub {