Changeset d5863e7221a302322c8481e6cee3bb3575232bae in xas-spooler


Ignore:
Timestamp:
11/10/15 09:50:56 (3 years ago)
Author:
Kevin L. Esteb <kevin@…>
Branches:
master
Children:
f8f5068b6d7b351efbd4791cac10e6a686fc31cd
Parents:
cd267643a706fc823f4192cf5614208bf5bf33c2
git-author:
Kevin L. Esteb <kevin@…> (11/10/15 09:50:56)
git-committer:
Kevin L. Esteb <kevin@…> (11/10/15 09:50:56)
Message:

working with concurrency

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/lib/XAS/Spooler/Processor.pm

    rcd267643a706fc823f4192cf5614208bf5bf33c2 rd5863e7221a302322c8481e6cee3bb3575232bae  
    178178    try { 
    179179 
    180         if (my $file = shift(@{$self->{'files'}})) { 
    181  
    182             if ($file->exists) { 
    183  
    184                 if (my $data = $self->spooler->read($file)) { 
    185  
    186                     $self->log->info_msg('spooler_found', $alias, $file->path); 
    187                     $poe_kernel->post($connector, 'send_packet', $alias, $type, $queue, $data, $file); 
     180        unless ($self->paused) { 
     181 
     182            if (my $file = shift(@{$self->{'files'}})) { 
     183 
     184                if ($file->exists) { 
     185 
     186                    if (my $data = $self->spooler->read($file)) { 
     187 
     188                        $self->log->info_msg('spooler_found', $alias, $file->path); 
     189                        $poe_kernel->post($connector, 'send_packet', $alias, $type, $queue, $data, $file); 
     190 
     191                    } 
    188192 
    189193                } 
Note: See TracChangeset for help on using the changeset viewer.