#8 bulk execution didn't respect Bulk::enabled

This commit is contained in:
Patrick Haßel 2022-10-26 20:06:21 +02:00
parent 929fc4d797
commit 5952871a3e

View File

@ -15,6 +15,10 @@ public class BulkExecutor {
private final PropertyWriteService propertyWriteService; private final PropertyWriteService propertyWriteService;
public void execute(final Bulk bulk) { public void execute(final Bulk bulk) {
if (!bulk.isEnabled()) {
log.info("Bulk disabled, not executing it: {}", bulk);
return;
}
log.info("Executing Bulk: {}", bulk); log.info("Executing Bulk: {}", bulk);
bulk.getEntries().forEach(entry -> propertyWriteService.writeToChannel(entry.getProperty(), entry.getValue())); bulk.getEntries().forEach(entry -> propertyWriteService.writeToChannel(entry.getProperty(), entry.getValue()));
log.debug("Finished executing Bulk: {}", bulk); log.debug("Finished executing Bulk: {}", bulk);