Move the testapp out of the main directory and under t/, avoiding the need for a...

[catagits/Catalyst-Engine-STOMP.git] / t / script / stomptestapp_stomp_workers.pl

diff --git a/t/script/stomptestapp_stomp_workers.pl b/t/script/stomptestapp_stomp_workers.pl
new file mode 100644 (file)
index 0000000..2120365
--- /dev/null
+++ b/t/script/stomptestapp_stomp_workers.pl
@@ -0,0 +1,46 @@
+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();
+