CPAN::Groonga

#!/usr/bin/perl
use strict;
use warnings;
use Net::AMQP::RabbitMQ;
use Getopt::Long;
use JSON;
use Time::HiRes qw(sleep);

our $VERSION = '0.1';

my $hostname = 'localhost';
my $user = 'guest';
my $pa

connect($hostname, { user => $user, password => $password });
$mq->channel_open($channel);
my $json = JSON->new;

my $i = 0;
my $uuids = {};
while (1) {
    my $msg = $mq->get($channel, $queue, {no_ac

f (!$msg) {
        last;
    }
    printf "Got message: %s\n", $msg->{body};
    my $uuid = from_json($msg->{body})->{uuid};
    if ($uuids->{$uuid}) {
        croak("UUID $uuid already met!");
    }

#!/usr/bin/perl
use strict;
use warnings;
use Carp;
use JSON;
use Getopt::Long;
use Data::Dumper;
use lib './lib';
use Net::AMQP::RabbitMQ::Batch;
use Time::HiRes qw(sleep);

our $VERSION = '0.3000';

 $msg (@$messages) {
        my $body = from_json($msg->{body});
        $body->{processed} = 1;
        my $new_msg = {
            body         => to_json($body)
        };
        push(@$new_mesage

#!/usr/bin/perl
use strict;
use warnings;
use Net::AMQP::RabbitMQ;
use Getopt::Long;
use JSON;
use Time::HiRes qw(sleep);

our $VERSION = '0.1';

my $hostname = 'localhost';
my $user = 'guest';
my $pa

 $i = 0;
while ($i < $messages) {
    my $uuid = time() * rand(10000) + $i;
    my $msg_body = to_json({msg => sprintf("Message number %d", $i), uuid => $uuid});
    $mq->publish($channel, $queue, $ms