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, status
public void cleanUp()
cleanUp
in class TaskManager
public io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> log()
log
in class TaskManager
public java.util.List<java.lang.String> getCurrentLogs(int offset)
getCurrentLogs
in class TaskManager
protected void pushLog(io.vertx.core.json.JsonObject log, boolean end)
pushLog
in class TaskManager
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2023. All Rights Reserved.