public class CQTaskManager extends TaskManager implements io.vertx.core.Handler<io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject>>
status, taskId| Constructor and Description | 
|---|
CQTaskManager(java.lang.String taskId)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
cleanUp()  | 
java.util.List<java.lang.String> | 
getCurrentLogs(int offset)  | 
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> | 
log()  | 
protected void | 
pushLog(io.vertx.core.json.JsonObject log,
       boolean end)  | 
java.lang.String | 
toString()  | 
getId, handle, statuspublic void cleanUp()
cleanUp in class TaskManagerpublic io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> log()
log in class TaskManagerpublic java.util.List<java.lang.String> getCurrentLogs(int offset)
getCurrentLogs in class TaskManagerprotected void pushLog(io.vertx.core.json.JsonObject log,
                       boolean end)
pushLog in class TaskManagerpublic java.lang.String toString()
toString in class java.lang.ObjectCopyright © 2023. All Rights Reserved.