public class BrokerRemovalRestartablePhase<T> extends java.lang.Object implements BrokerRemovalPhase<T>
Modifier and Type | Class and Description |
---|---|
static class |
BrokerRemovalRestartablePhase.BrokerRemovalRestartablePhaseBuilder<T> |
Modifier and Type | Method and Description |
---|---|
T |
execute(BrokerRemovalOptions args)
Execute the broker removal phase
|
boolean |
hasSkippedExecution() |
BrokerRemovalStateMachine.BrokerRemovalState |
startState()
Returns the broker removal state to which this state applies.
|
public T execute(BrokerRemovalOptions args) throws java.lang.Exception
BrokerRemovalPhase
execute
in interface BrokerRemovalPhase<T>
java.lang.Exception
- - if anything goes wrong during phase executionpublic boolean hasSkippedExecution()
hasSkippedExecution
in interface BrokerRemovalPhase<T>
public BrokerRemovalStateMachine.BrokerRemovalState startState()
BrokerRemovalPhase
startState
in interface BrokerRemovalPhase<T>