Yet Another CPAN Grep

Message-Passing-AMQP-Proxy ( D/DL/DLAMBLEY/Message-Passing-AMQP-Proxy-0.002.tar.gz, DLAMBLEY, 2012; MetaCPAN )

Message-Passing-AMQP-Proxy/lib/Message/Passing/AMQP/Proxy.pm ( view source; MetaCPAN )

sage::Passing>, filtering JSON messages into
specified exchanges with specified routeing keys.

=over

=item *

The exchange is specified by the C<@exchange> field in the JSON data.

=item *

The rout

eing key is specified by the C<@rk> field in the JSON data.

=back

=head1 AUTHOR

Dave Lambley, based on work by Tomas (t0m) Doran.

=head1 LICENSE

GNU Affero General Public License, Version 3

=cut

Message-Passing-AMQP-Proxy ( D/DL/DLAMBLEY/Message-Passing-AMQP-Proxy-0.002.tar.gz, DLAMBLEY, 2012; MetaCPAN )

Message-Passing-AMQP-Proxy/lib/Message/Passing/Output/AMQP/Proxy.pm ( view source; MetaCPAN )

package Message::Passing::Output::AMQP::Proxy;
use Moose;
use namespace::autoclean;
use JSON qw/ decode_json /;

with qw/
    Message::Passing::AMQP::Role::HasAChannel
    Message::Passing::Role::Outp

erialized data - is a perl reference. Dropping.\n");
        return;
    }

    my $hash = decode_json($data);

    $self->_channel->publish(
        body => $data,
        exchange => $hash->{'@excha