Package org.flowable.external.worker.listener.adapter

Class MessagingWorkerJobListenerAdapter

java.lang.Object

org.flowable.external.worker.listener.adapter.MessagingWorkerJobListenerAdapter

All Implemented Interfaces:

FlowableWorkerJobListener, WorkerContextAwareFlowableWorkerJobListener

public class MessagingWorkerJobListenerAdapter
extends Object
implements WorkerContextAwareFlowableWorkerJobListener

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.springframework.messaging.handler.invocation.InvocableHandlerMethod	handlerMethod
protected final org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
MessagingWorkerJobListenerAdapter(org.springframework.messaging.handler.invocation.InvocableHandlerMethod handlerMethod)

Method Summary

Modifier and Type	Method	Description
protected String	createMessagingErrorMessage(String description)
protected void	handleResult(Object result, AcquiredExternalWorkerJob job, WorkerContext workerContext)
protected Object	invokeHandler(AcquiredExternalWorkerJob job, org.springframework.messaging.Message<?> message, WorkerContext workerContext)
void	onAcquiredJob(AcquiredExternalWorkerJob job, WorkerContext workerContext)
protected org.springframework.messaging.Message<?>	toMessagingMessage(AcquiredExternalWorkerJob job)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.flowable.external.worker.WorkerContextAwareFlowableWorkerJobListener

onAcquiredJob

Field Details

logger

protected final org.slf4j.Logger logger

handlerMethod

protected final org.springframework.messaging.handler.invocation.InvocableHandlerMethod handlerMethod

Constructor Details

MessagingWorkerJobListenerAdapter

public MessagingWorkerJobListenerAdapter(org.springframework.messaging.handler.invocation.InvocableHandlerMethod handlerMethod)

Method Details

onAcquiredJob

public void onAcquiredJob(AcquiredExternalWorkerJob job,
 WorkerContext workerContext)

Specified by:

onAcquiredJob in interface FlowableWorkerJobListener

Specified by:

onAcquiredJob in interface WorkerContextAwareFlowableWorkerJobListener

toMessagingMessage

protected org.springframework.messaging.Message<?> toMessagingMessage(AcquiredExternalWorkerJob job)

invokeHandler

protected Object invokeHandler(AcquiredExternalWorkerJob job,
 org.springframework.messaging.Message<?> message,
 WorkerContext workerContext)

handleResult

protected void handleResult(Object result,
 AcquiredExternalWorkerJob job,
 WorkerContext workerContext)

createMessagingErrorMessage

protected String createMessagingErrorMessage(String description)