diff --git a/pom.xml b/pom.xml index ab97d9e..a5ef9e6 100755 --- a/pom.xml +++ b/pom.xml @@ -4,7 +4,7 @@ lm-lib de.extio lm-lib - 1.6.15 + 1.6.16 21 diff --git a/src/main/java/de/extio/lmlib/agent/AgentExecutorService.java b/src/main/java/de/extio/lmlib/agent/AgentExecutorService.java index e630ddf..1d93d32 100755 --- a/src/main/java/de/extio/lmlib/agent/AgentExecutorService.java +++ b/src/main/java/de/extio/lmlib/agent/AgentExecutorService.java @@ -69,6 +69,13 @@ public class AgentExecutorService implements InitializingBean, DisposableBean { } public List walk(final BaseAgent agent, final AgentContext context, final Consumer agentContextUpdateConsumer) { + if (!context.getGraph().isEmpty()) { + context.getGraph().add("‖"); + } + return this.walkRecursive(agent, context, agentContextUpdateConsumer); + } + + private List walkRecursive(final BaseAgent agent, final AgentContext context, final Consumer agentContextUpdateConsumer) { LOGGER.debug("Agent: {}", agent.name()); this.discoverAgents(context); @@ -96,7 +103,7 @@ public class AgentExecutorService implements InitializingBean, DisposableBean { branchTasks.add(CompletableFuture.runAsync(() -> { try { - responses.addAll(this.walk(branchAgent, branchContext, agentContextUpdateConsumer)); + responses.addAll(this.walkRecursive(branchAgent, branchContext, agentContextUpdateConsumer)); } catch (final Exception e) { LOGGER.error("Error executing agent", e);