package net.pterodactylus.rhynodge.engine;
-import static com.google.common.base.Optional.absent;
-import static com.google.common.base.Optional.of;
import static com.google.common.collect.Maps.newTreeMap;
import static java.lang.String.format;
+import static java.util.Optional.empty;
+import static java.util.Optional.of;
import java.util.HashMap;
import java.util.Map;
import java.util.Map.Entry;
+import java.util.Optional;
import java.util.SortedMap;
import net.pterodactylus.rhynodge.Filter;
import net.pterodactylus.rhynodge.states.FailedState;
import net.pterodactylus.rhynodge.states.StateManager;
-import com.google.common.base.Optional;
import com.google.common.util.concurrent.AbstractExecutionThreadService;
import org.apache.commons.lang3.tuple.Pair;
import org.apache.log4j.Logger;
continue;
}
- /* run reaction. */
- logger.info(format("Running Query for %s...", reactionName));
- Query query = nextReaction.get().getReaction().query();
- net.pterodactylus.rhynodge.State state;
- try {
- logger.debug("Querying system...");
- state = query.state();
- if (state == null) {
- state = FailedState.INSTANCE;
- }
- logger.debug("System queried.");
- } catch (Throwable t1) {
- logger.warn("Querying system failed!", t1);
- state = new AbstractState(t1) {
- /* no further state. */
- };
- }
+ net.pterodactylus.rhynodge.State state = runReaction(nextReaction, reactionName);
logger.debug(format("State is %s.", state));
/* convert states. */
}
}
+ private net.pterodactylus.rhynodge.State runReaction(Optional<NextReaction> nextReaction, String reactionName) {
+ logger.info(format("Running Query for %s...", reactionName));
+ Query query = nextReaction.get().getReaction().query();
+ net.pterodactylus.rhynodge.State state;
+ try {
+ logger.debug("Querying system...");
+ state = query.state();
+ if (state == null) {
+ state = FailedState.INSTANCE;
+ }
+ logger.debug("System queried.");
+ } catch (Throwable t1) {
+ logger.warn("Querying system failed!", t1);
+ state = new AbstractState(t1) {
+ };
+ }
+ return state;
+ }
+
private void waitForNextReactionToStart(Optional<NextReaction> nextReaction, long waitTime) {
synchronized (reactions) {
try {
return of(new NextReaction(keyReaction.getKey(), keyReaction.getValue(), nextReactions.firstKey()));
}
}
- return absent();
+ return empty();
}
private static class NextReaction {