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