AnyEvent-Beanstalk-Worker

 view release on metacpan or  search on metacpan

eg/ssh-add.pl  view on Meta::CPAN

#!/usr/bin/env perl
use strict;
use warnings;
use AnyEvent::Beanstalk;
use JSON;
use Data::Dumper;
use feature 'say';

my $bs = AnyEvent::Beanstalk->new
  (server => 'localhost',
   encoder => sub { encode_json(shift) });

$bs->use('ssh-jobs')->recv;

my @scripts = ();
push @scripts, {interpreter => "/bin/sh",

eg/ssh.pl  view on Meta::CPAN

#!/usr/bin/env perl
use strict;
use warnings;
use feature 'say';
use JSON;
use Data::Dumper;
use AnyEvent::Open3::Simple;
use EV;

use blib;
use AnyEvent::Beanstalk::Worker;

my $w = AnyEvent::Beanstalk::Worker->new(
    max_jobs          => 1,
    initial_state     => 'run',
    beanstalk_watch   => 'ssh-jobs',

eg/web-add.pl  view on Meta::CPAN

#!/usr/bin/env perl
use strict;
use warnings;
use AnyEvent::Beanstalk;
use Mojo::UserAgent;
use JSON;
use Data::Dumper;

my @urls = ();

if (@ARGV) {
    push @urls, @ARGV;
}

else {
    my $ua = Mojo::UserAgent->new;
    my $tx = $ua->get('http://www.uroulette.com/');

eg/web-state-add.pl  view on Meta::CPAN

#!/usr/bin/env perl
use strict;
use warnings;
use AnyEvent::Beanstalk;
use Data::Dumper;

my $bs = AnyEvent::Beanstalk->new
  (server => 'localhost');

$bs->use('urls')->recv;

my $job = $bs->put({ priority => 100,
                     ttr      => 15,
                     delay    => 1,
                     data     => "http://www.uroulette.com/"})->recv;

lib/AnyEvent/Beanstalk/Worker.pm  view on Meta::CPAN

1;
__END__

=head1 NAME

AnyEvent::Beanstalk::Worker - Event-driven FSA for beanstalk queues

=head1 SYNOPSIS

  use AnyEvent::Beanstalk::Worker;
  use Data::Dumper;
  use JSON;

  my $w = AnyEvent::Beanstalk::Worker->new(
      concurrency       => 10,
      initial_state     => 'reserved',
      beanstalk_watch   => 'jobs',
      beanstalk_decoder => sub {
          eval { decode_json(shift) };
      }
  );