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
FieldsModifier and TypeFieldDescriptionprotected final org.springframework.messaging.handler.invocation.InvocableHandlerMethodprotected final org.slf4j.Logger -
Constructor Summary
ConstructorsConstructorDescriptionMessagingWorkerJobListenerAdapter(org.springframework.messaging.handler.invocation.InvocableHandlerMethod handlerMethod) -
Method Summary
Modifier and TypeMethodDescriptionprotected StringcreateMessagingErrorMessage(String description) protected voidhandleResult(Object result, AcquiredExternalWorkerJob job, WorkerContext workerContext) protected ObjectinvokeHandler(AcquiredExternalWorkerJob job, org.springframework.messaging.Message<?> message, WorkerContext workerContext) voidonAcquiredJob(AcquiredExternalWorkerJob job, WorkerContext workerContext) protected org.springframework.messaging.Message<?>Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods 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
- Specified by:
onAcquiredJobin interfaceFlowableWorkerJobListener- Specified by:
onAcquiredJobin interfaceWorkerContextAwareFlowableWorkerJobListener
-
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
-