net.bluemind.core.task.service.internal

Class TaskManager

java.lang.Object

net.bluemind.core.task.service.internal.TaskManager

All Implemented Interfaces:

io.vertx.core.Handler<io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject>>

Direct Known Subclasses:

CQTaskManager

public abstract class TaskManager
extends java.lang.Object
implements io.vertx.core.Handler<io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject>>

Field Summary

Fields

Modifier and Type	Field and Description
protected TaskStatus	status
protected java.lang.String	taskId

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TaskManager(java.lang.String taskId)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
abstract java.util.List<java.lang.String>	getCurrentLogs(int offset)
java.lang.String	getId()
void	handle(io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject> event)
abstract io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>	log()
protected abstract void	pushLog(io.vertx.core.json.JsonObject log, boolean end)
TaskStatus	status()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

taskId

protected final java.lang.String taskId

status

protected TaskStatus status

Constructor Detail

TaskManager

protected TaskManager(java.lang.String taskId)

Method Detail

cleanUp

public void cleanUp()

log

public abstract io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> log()

getCurrentLogs

public abstract java.util.List<java.lang.String> getCurrentLogs(int offset)

handle

public final void handle(io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject> event)

Specified by:

handle in interface io.vertx.core.Handler<io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject>>

pushLog

protected abstract void pushLog(io.vertx.core.json.JsonObject log,
                                boolean end)

status

public final TaskStatus status()

getId

public final java.lang.String getId()