public class BrokerRemovalRestartablePhase<T> extends Object implements BrokerRemovalPhase<T>
Modifier and Type | Class and Description |
---|---|
static class |
BrokerRemovalRestartablePhase.BrokerRemovalRestartablePhaseBuilder<T> |
Modifier and Type | Method and Description |
---|---|
T |
execute(BrokerRemovalContext context)
Execute the broker removal phase
|
boolean |
hasSkippedExecution() |
BrokerRemovalStateMachine.BrokerRemovalState |
startState()
Returns the broker removal state to which this state applies.
|
public T execute(BrokerRemovalContext context) throws Exception
BrokerRemovalPhase
execute
in interface BrokerRemovalPhase<T>
Exception
- - if anything goes wrong during phase executionpublic boolean hasSkippedExecution()
hasSkippedExecution
in interface BrokerRemovalPhase<T>
public BrokerRemovalStateMachine.BrokerRemovalState startState()
BrokerRemovalPhase
BrokerRemovalRestartablePhase
can be in
alwaysExecute mode in which case the return value of this is irrelevant.startState
in interface BrokerRemovalPhase<T>