use warnings;
 use strict;
 use POE;
 use POE::Component::DirWatch;
 POE::Session->create(
              inline_states => {
                  _start => \&init_watcher,
                  watch_dir => \&watch_dir,
                               },
                    );


 sub init_watcher {
   my ($kernel, $heap, $session, $sender) = @_[KERNEL, HEAP, SESSION, SENDER];
   warn "Queue 1 starting (session id " . $session->ID . ")";

  # watch a directory for this queue
  $kernel->yield('watch_dir', '/tmp/queue1'); }


 sub watch_dir {
     my ($kernel, $heap, $session, $queue) = @_[KERNEL, HEAP, SESSION, ARG0];

# start watching the directory
    POE::Component::DirWatch->new(
                             alias => 'dirwatch',
                             directory => $queue,
                             file_callback => \&found_file,
                             interval => 1,
                             );
}

sub found_file {
    my ($kernel, $heap, $session, $sender, $file) = @_[KERNEL, HEAP, SESSION, SENDER, ARG1];

#    warn "Found '$file' for " . $session->ID . " (from " . $sender-ID . ")\n";
    warn "Found '$file' for $session->ID\n";

}

$poe_kernel->run();
exit(0);

 

##</code><code>##

 -bash-3.00$ ./dirwatch_test1.pl
  Queue 1 starting (session id 2) at ./dirwatch_test1.pl line 19.
  Found '' for ->ID
  Found '' for ->ID