#!/usr/bin/env perl
use 5.12.2;
use Crixa;
my $mq = Crixa->connect( host => 'localhost', );
my $q = $mq->queue( name => 'hello' );
$q->handle_message( sub { say $_->{body} } );
__END__
#!/usr/bin/env perl
use 5.12.2;
use Crixa;
my $mq = Crixa->connect( host => 'localhost', );
my $q = $mq->queue( name => 'hello' );
$q->handle_message( sub { say $_->{body} } );
__END__