public final class DriverStatusManager extends Object
Modifier and Type | Method and Description |
---|---|
boolean |
isShuttingDownOrFailing() |
void |
onComplete()
Perform a clean shutdown of the Driver.
|
void |
onError(Throwable exception)
End the Driver with an exception.
|
void |
onInit()
Changes the driver status to INIT and sends message to the client about the transition.
|
void |
onRunning()
Changes the driver status to RUNNING and sends message to the client about the transition.
|
void |
sendJobEndingMessageToClient(Optional<Throwable> exception)
Sends the final message to the Driver.
|
public void onInit()
public void onRunning()
public void onError(Throwable exception)
exception
- public void onComplete()
public void sendJobEndingMessageToClient(Optional<Throwable> exception)
exception
- public boolean isShuttingDownOrFailing()
Copyright © 2016 The Apache Software Foundation. All rights reserved.