diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-26 21:20:12 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-26 21:20:12 +0200 |
| commit | c9c2e127a921886073c14c228b8c9b427f216b6b (patch) | |
| tree | 7e8b97b72897426795ba49c31cc3cdd238158c73 | |
| parent | 02a30adac0f92366ef9e6118581e39602b6d0d39 (diff) | |
| download | processor-c9c2e127a921886073c14c228b8c9b427f216b6b.tar.gz processor-c9c2e127a921886073c14c228b8c9b427f216b6b.zip | |
fix deadlock catching?release/2.14.0
| -rw-r--r-- | worker.js | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -284,7 +284,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { { persistent: true })); } catch (err) { if (err instanceof Seq.TimeoutError || - (err instanceof Seq.DatabaseError && err.code == 1213)) { + (err instanceof Seq.DatabaseError && err.errno == 1213)) { // deadlocks / timeout logger.error("SQL error", err); await Promise.map(msgs, async (m) => |
