@ThreadSafe @Service(value=Worker.class) @Properties(value=@Property(name="type",value="logging")) public final class LoggingWorker extends AbstractComponent implements Worker
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
TYPE |
Constructor and Description |
---|
LoggingWorker() |
Modifier and Type | Method and Description |
---|---|
void |
assign(TaskContext context,
java.util.Set<WorkItem> workItems)
Start processing the assigned
WorkItem items of the specified task. |
java.lang.String |
getType() |
void |
release(TaskContext context,
java.util.Set<WorkItem> workItems)
Stop processing the assigned
WorkItem items of the specified task. |
void |
stop(TaskContext context)
Stops processing of items.
|
void |
stopAll()
Stops processing of items.
|
activateComponent, assertValid, deactivateComponent, isValid
public static final java.lang.String TYPE
public void assign(TaskContext context, java.util.Set<WorkItem> workItems)
Worker
WorkItem
items of the specified task.public void release(TaskContext context, java.util.Set<WorkItem> workItems)
Worker
WorkItem
items of the specified task.public void stop(TaskContext context)
Worker
Copyright © 2017 Red Hat. All Rights Reserved.