Shane Utt
and 1 contributors

NAME

WWW::RabbitMQ::Broker

SYNOPSIS

        # Make a call to a RabbitMQ API on a broker...
        my $broker = WWW::RabbitMQ::Broker->new(
                username => 'guest',
                password => 'guest,
                host     => 'localhost',
        );

        # get an overview of the system
        my $overview = $broker->overview;

        # get all nodes in the cluster
        my $nodes = $broker->nodes;

        # get all open connections
        my $connections = $broker->connections;

        # publish a message to an exchange
        my $res = $broker->uriRequestMethod('POST')->exchanges->$vhost->$name->publish({
                payload          => "mymessage",
                payload_encoding => "string",
                properties       => {},
                routing_key      => "mykey",
        });

        # configure a shovel
        my $res = $broker->uriRequestMethod('PUT')->parameters->shovel->$vhost->$myshovel({
                value => {
                        src-uri    => "amqp://",
                        src-queue  => "my-queue",
                        dest-uri   => "amqp://remote-server",
                        dest-queue => "another-queue",
                },
        });

DESCRIPTION

A simple module that generically interacts with the RabbitMQ API