rabbitmq parent

rabbitmq_child.pl

use strict;
use warnings;
use feature 'say';

use JSON;
use Net::RabbitMQ;
use Data::Dumper;

my $queue = shift @ARGV || die "No queue specified";

say "$queue starting...";
my $mq = Net::RabbitMQ->new();
$mq->connect("localhost", {});
$mq->channel_open(1);

while ( 1 ) {
    $mq->consume(1, $queue);
    my $msg = from_json( $mq->recv()->{body} );

    if ($msg->{done}) {
        say "$queue got shutdown request";
        last;
    }

    say "$queue got...";
    say Dumper $msg;
}

say "$queue cleaning up.";

$mq->disconnect();

rabbitmq_parent.pl

use warnings;
use strict;
use feature 'say';

use JSON;
use Net::RabbitMQ;

# Get requested number of child processes XXX later use GetOpts
my $num_children = shift @ARGV || 1;

my $mq = Net::RabbitMQ->new();
$mq->connect("localhost", {});
$mq->channel_open(1);

# XXX preamble
my $jobs = [
    { rick => {never=>'gonna'} },
    { rick => {give=>'you'}    },
    { rick => {up=>'never'}    },
    { rick => {gonna=>'let'}   },
    { rick => {you=>'down'}    },
    { rick => {never=>'gonna'} },
    { rick => {run=>'around'}  },
    { rick => {'and'=>'desert'}},
    { rick => {you=>'never'}   },
    { rick => {gonna=>'make'}  },
    { rick => {you=>'cry'}     },
    { rick => {'tell'=>'a'}    },
    { rick => {lie=>'never'}   },
    { rick => {gonna=>'say'}   },
    { rick => {goodbye=>'and'} },
    { rick => {hurt=>'you'}    }
];

for my $i ( 1..$num_children ) {
    my $queue = "child_$i";
    $mq->queue_declare(1, $queue);
    # could be more sophisticated
    `perl mqtest_cl.pl $queue > $queue.log &`;
}

my $i = 1;
while ( scalar @$jobs ) {
    my $job = shift @$jobs;
    my $json = to_json($job);
    $mq->publish(1, "child_$i", $json);
    if ( ++$i > $num_children ) { $i = 1; }
}

for $i ( 1..$num_children ) {
    my $json = to_json( { done => 1 } );
    $mq->publish(1, "child_$i", $json);
}

say "parent cleaning up...";

$mq->disconnect();