X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=testapp%2Fscript%2Fstomptestapp_stomp_workers.pl;fp=testapp%2Fscript%2Fstomptestapp_stomp_workers.pl;h=0000000000000000000000000000000000000000;hb=3df1f3be5d21a8ff08c4564539c9b0d70590b93f;hp=2120365448c87590209883452a6ac5479411b865;hpb=1525c58383c49694856673944b2e26103a5b49df;p=catagits%2FCatalyst-Engine-STOMP.git diff --git a/testapp/script/stomptestapp_stomp_workers.pl b/testapp/script/stomptestapp_stomp_workers.pl deleted file mode 100644 index 2120365..0000000 --- a/testapp/script/stomptestapp_stomp_workers.pl +++ /dev/null @@ -1,46 +0,0 @@ -package Manager; -use Moose; -with qw(MooseX::Workers); - -BEGIN { - $ENV{CATALYST_ENGINE} = 'Stomp'; - require Catalyst::Engine::Stomp; -} - -use FindBin; -use lib "$FindBin::Bin/../lib"; - -sub run { - my $self = shift; - for my $i (1..4) { - $self->spawn( sub { - require StompTestApp; - StompTestApp->run(); - } ); - } - POE::Kernel->run(); -} - -# Implement our Interface -sub worker_manager_start { warn 'started worker manager' } -sub worker_manager_stop { warn 'stopped worker manager' } -sub max_workers_reached { warn 'maximum worker count reached' } - -sub worker_stdout { shift; warn join ' ', @_; } -sub worker_stderr { shift; warn join ' ', @_; } -sub worker_error { shift; warn join ' ', @_; } -sub worker_done { - my $self = shift; - warn "restarting"; - $self->spawn( sub { - require StompTestApp; - StompTestApp->run(); - } ); -} -sub worker_started { shift; warn join ' ', @_; } -sub sig_child { shift; warn join ' ', @_; } -no Moose; - -my $manager = Manager->new(); -$manager->run(); -