Package io.vertigo.stella.impl.workers

Interface WorkersPlugin

All Superinterfaces:

io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Plugin

All Known Implementing Classes:

RedisWorkersPlugin, RestWorkersPlugin

public interface WorkersPlugin
extends io.vertigo.core.node.component.Plugin

NodePlugin

Author:

pchretien

Method Summary

Modifier and Type	Method	Description
<R,W> WorkItem<R,W>	pollWorkItem(String nodeId, String workType)	Polling workitem.
<R> void	putResult(String workId, R result, Throwable error)	Send result or error if execution failed
void	putStart(String workId)

Method Detail

pollWorkItem

<R,W> WorkItem<R,W> pollWorkItem(String nodeId,
                                             String workType)

Polling workitem.

Type Parameters:

R - result

W - work

Parameters:

workType - Type de tache

Returns:

Workitem or null (if timeout)

putResult

<R> void putResult(String workId,
                   R result,
                   Throwable error)

Send result or error if execution failed

Type Parameters:

R - result

Parameters:

workId - WorkId

result - Result (not null if execution succeeded)

error - Error ( not null if execution failed)

putStart

void putStart(String workId)