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
void	heartBeat(String nodeId, Set<String> workTypes)
<R, W> WorkItem<R,W>	pollWorkItem(String nodeId, String workType)	Polling workitem.
<R> void	putResult(String callerNodeId, String nodeId, String workType, String workId, R result, Throwable error)	Send result or error if execution failed
void	putStart(String nodeId, String workType, String workId)

Method Details

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 callerNodeId,
 String nodeId,
 String workType,
 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 nodeId,
 String workType,
 String workId)

heartBeat

void heartBeat(String nodeId,
 Set<String> workTypes)