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 © 2024. All Rights Reserved.