Interface PojoMassIndexerAgent
-
public interface PojoMassIndexerAgent
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static PojoMassIndexerAgent
noOp()
CompletableFuture<?>
preStop()
Performs preliminary operations necessary to safely stop this agent.CompletableFuture<?>
start()
Starts requesting from other agents that could possibly perform indexing (e.g.void
stop()
Stops this agent.
-
-
-
Method Detail
-
noOp
static PojoMassIndexerAgent noOp()
-
start
CompletableFuture<?> start()
Starts requesting from other agents that could possibly perform indexing (e.g. automatic indexing) that they suspend themselves.Other agents can be considered suspended when the returned future completes successfully; they will remain suspended until this agent is
pre-stoppped
orstopped
.- Returns:
- A future that completes successfully when other agents have been successfully suspended. If no agents can be suspended (e.g. no coordination), returns a successfully completed future immediately.
-
preStop
CompletableFuture<?> preStop()
Performs preliminary operations necessary to safely stop this agent.This should be called before
stop()
, unless other errors are forcing us to make an emergency stop.- Returns:
- A future that completes successfully when the agent has stopped.
-
stop
void stop()
Stops this agent.
-
-