Lines 69-74
my ( $help, $batch_size );
Link Here
|
69 |
|
69 |
|
70 |
my $not_found_retries = {}; |
70 |
my $not_found_retries = {}; |
71 |
my $max_retries = $ENV{MAX_RETRIES} || 10; |
71 |
my $max_retries = $ENV{MAX_RETRIES} || 10; |
|
|
72 |
my $mq_timeout = $ENV{MQ_TIMEOUT} // 10; |
72 |
|
73 |
|
73 |
GetOptions( |
74 |
GetOptions( |
74 |
'h|help' => \$help, |
75 |
'h|help' => \$help, |
Lines 111-119
my @jobs = ();
Link Here
|
111 |
while (1) { |
112 |
while (1) { |
112 |
|
113 |
|
113 |
if ( $conn ) { |
114 |
if ( $conn ) { |
114 |
my $frame = $conn->receive_frame; |
115 |
my $frame = $conn->receive_frame( { timeout => $mq_timeout } ); |
115 |
if ( !defined $frame ) { |
116 |
if ( !defined $frame ) { |
116 |
# maybe log connection problems |
117 |
# timeout or connection issue? |
|
|
118 |
$pm->reap_finished_children; |
117 |
next; # will reconnect automatically |
119 |
next; # will reconnect automatically |
118 |
} |
120 |
} |
119 |
|
121 |
|
120 |
- |
|
|