Lines 99-104
while (1) {
Link Here
|
99 |
decode_json($body); # TODO Should this be from_json? Check utf8 flag. |
99 |
decode_json($body); # TODO Should this be from_json? Check utf8 flag. |
100 |
} catch { |
100 |
} catch { |
101 |
Koha::Logger->get->warn(sprintf "Frame not processed - %s", $_); |
101 |
Koha::Logger->get->warn(sprintf "Frame not processed - %s", $_); |
|
|
102 |
return; |
102 |
} finally { |
103 |
} finally { |
103 |
$conn->ack( { frame => $frame } ); |
104 |
$conn->ack( { frame => $frame } ); |
104 |
}; |
105 |
}; |
Lines 124-129
while (1) {
Link Here
|
124 |
} catch { |
125 |
} catch { |
125 |
Koha::Logger->get->warn(sprintf "Cannot decode data for job id=%s", $job->id); |
126 |
Koha::Logger->get->warn(sprintf "Cannot decode data for job id=%s", $job->id); |
126 |
$job->status('failed')->store; |
127 |
$job->status('failed')->store; |
|
|
128 |
return; |
127 |
}; |
129 |
}; |
128 |
|
130 |
|
129 |
next unless $args; |
131 |
next unless $args; |
130 |
- |
|
|