|
|
@ -414,14 +414,6 @@ class Core {
|
|
|
|
continue;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (op.tries >= TOTAL_RETRY_MAX) {
|
|
|
|
|
|
|
|
// Giving up
|
|
|
|
|
|
|
|
op.cleanup(context);
|
|
|
|
|
|
|
|
db.operation().deleteOperation(op.id);
|
|
|
|
|
|
|
|
ops.remove(op);
|
|
|
|
|
|
|
|
continue;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
db.beginTransaction();
|
|
|
|
db.beginTransaction();
|
|
|
|
|
|
|
|
|
|
|
@ -436,7 +428,8 @@ class Core {
|
|
|
|
db.endTransaction();
|
|
|
|
db.endTransaction();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (ex instanceof OutOfMemoryError ||
|
|
|
|
if (op.tries >= TOTAL_RETRY_MAX ||
|
|
|
|
|
|
|
|
ex instanceof OutOfMemoryError ||
|
|
|
|
ex instanceof MessageRemovedException ||
|
|
|
|
ex instanceof MessageRemovedException ||
|
|
|
|
ex instanceof MessageRemovedIOException ||
|
|
|
|
ex instanceof MessageRemovedIOException ||
|
|
|
|
ex instanceof FileNotFoundException ||
|
|
|
|
ex instanceof FileNotFoundException ||
|
|
|
|