X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Freactor%2Fengine%2FEngine.java;h=6f4376b7569f6088c95d1003907f4b47215dba26;hb=a41f3ea11b088b0ebc17dcc8150f556b78aa7dd8;hp=79ea4828c0a568a83b3985504d704903c220ca10;hpb=45488abc39f14a520dfe7926d9eacc479f302fcb;p=rhynodge.git diff --git a/src/main/java/net/pterodactylus/reactor/engine/Engine.java b/src/main/java/net/pterodactylus/reactor/engine/Engine.java index 79ea482..6f4376b 100644 --- a/src/main/java/net/pterodactylus/reactor/engine/Engine.java +++ b/src/main/java/net/pterodactylus/reactor/engine/Engine.java @@ -47,12 +47,22 @@ public class Engine extends AbstractExecutionThreadService { private static final Logger logger = Logger.getLogger(Engine.class); /** The state manager. */ - private final StateManager stateManager = new StateManager("states"); + private final StateManager stateManager; /** All defined reactions. */ /* synchronize on itself. */ private final Map reactions = new HashMap(); + /** + * Creates a new engine. + * + * @param stateManager + * The state manager + */ + public Engine(StateManager stateManager) { + this.stateManager = stateManager; + } + // // ACCESSORS // @@ -136,7 +146,7 @@ public class Engine extends AbstractExecutionThreadService { if (waitTime > 0) { synchronized (reactions) { try { - logger.debug(String.format("Waiting for %d milliseconds.", waitTime)); + logger.info(String.format("Waiting until %tc.", lastStateTime + nextReaction.updateInterval())); reactions.wait(waitTime); } catch (InterruptedException ie1) { /* we’re looping! */ @@ -192,7 +202,7 @@ public class Engine extends AbstractExecutionThreadService { logger.debug(String.format("Trigger was hit: %s.", triggerHit)); if (triggerHit) { logger.info("Executing Action..."); - nextReaction.action().execute(trigger.output()); + nextReaction.action().execute(trigger.output(nextReaction)); } }