|
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 |
- |
|
|