@ThreadSafe @Service(value=Worker.class) @Properties(value=@Property(name="type",value="logging")) public final class LoggingWorker extends io.fabric8.api.scr.AbstractComponent implements Worker
Constructor and Description |
---|
LoggingWorker() |
Modifier and Type | Method and Description |
---|---|
void |
assign(TaskContext context,
Set<WorkItem> workItems)
Start processing the assigned
WorkItem items of the specified task. |
String |
getType() |
void |
release(TaskContext context,
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.
|
public static final String TYPE
public void assign(TaskContext context, Set<WorkItem> workItems)
Worker
WorkItem
items of the specified task.public void release(TaskContext context, Set<WorkItem> workItems)
Worker
WorkItem
items of the specified task.public void stop(TaskContext context)
Worker
Copyright © 2011–2014 Red Hat. All rights reserved.