Class QueueBasedProcessStarter

java.lang.Object

org.chenile.orchestrator.process.QueueBasedProcessStarter

All Implemented Interfaces:

WorkerStarter

public class QueueBasedProcessStarter
extends Object
implements WorkerStarter

Field Summary

Fields

Modifier and Type	Field	Description
(package private) ChenilePub	chenilePub
private final org.slf4j.Logger	logger
(package private) ObjectMapper	objectMapper
String	topicNameTemplate

Constructor Summary

Constructors

Constructor	Description
QueueBasedProcessStarter()

Method Summary

Modifier and Type	Method	Description
void	start(WorkerDto workerDto)

Methods inherited from class Object

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

Field Details

logger

private final org.slf4j.Logger logger

topicNameTemplate

public String topicNameTemplate

chenilePub

@Autowired
ChenilePub chenilePub

objectMapper

ObjectMapper objectMapper

Constructor Details

QueueBasedProcessStarter

public QueueBasedProcessStarter()

Method Details

start

public void start(WorkerDto workerDto)

Specified by:

start in interface WorkerStarter