Fixed queuing daily rules

pull/212/head
M66B 2 years ago
parent c31adebf5a
commit d95cc81bcf

@ -108,13 +108,12 @@ public class WorkerDailyRules extends Worker {
EntityOperation.queue(context, message, EntityOperation.BODY); EntityOperation.queue(context, message, EntityOperation.BODY);
} }
if (defer) { if (defer)
EntityOperation.queue(context, message, EntityOperation.RULE, -1L); EntityOperation.queue(context, message, EntityOperation.RULE, -1L);
continue; else {
}
EntityLog.log(context, "Executing daily rules message=" + message.id); EntityLog.log(context, "Executing daily rules message=" + message.id);
EntityRule.run(context, rules, message, null, null); EntityRule.run(context, rules, message, null, null);
}
db.setTransactionSuccessful(); db.setTransactionSuccessful();
} catch (Throwable ex) { } catch (Throwable ex) {

Loading…
Cancel
Save