|
|
@ -485,11 +485,7 @@ class Core {
|
|
|
|
db.operation().deleteOperation(op.id);
|
|
|
|
db.operation().deleteOperation(op.id);
|
|
|
|
|
|
|
|
|
|
|
|
// Cleanup messages
|
|
|
|
// Cleanup messages
|
|
|
|
if (message != null &&
|
|
|
|
if (message != null && MessageHelper.isRemoved(ex))
|
|
|
|
(ex instanceof MessageRemovedException ||
|
|
|
|
|
|
|
|
ex instanceof MessageRemovedIOException ||
|
|
|
|
|
|
|
|
ex.getCause() instanceof MessageRemovedException ||
|
|
|
|
|
|
|
|
ex.getCause() instanceof MessageRemovedIOException))
|
|
|
|
|
|
|
|
db.message().deleteMessage(message.id);
|
|
|
|
db.message().deleteMessage(message.id);
|
|
|
|
|
|
|
|
|
|
|
|
db.setTransactionSuccessful();
|
|
|
|
db.setTransactionSuccessful();
|
|
|
|