Package org.flowable.external.worker.config

Class MethodFlowableWorkerEndpoint

java.lang.Object

org.flowable.external.worker.config.AbstractFlowableWorkerEndpoint

org.flowable.external.worker.config.MethodFlowableWorkerEndpoint

All Implemented Interfaces:

FlowableWorkerEndpoint

public class MethodFlowableWorkerEndpoint
extends AbstractFlowableWorkerEndpoint

A FlowableWorkerEndpoint providing the method to invoke to process an incoming message for this endpoint.

Author:

Filip Hrisafov

Field Summary

Fields inherited from class org.flowable.external.worker.config.AbstractFlowableWorkerEndpoint

concurrency, id, lockDuration, numberOfRetries, numberOfTasks, pollingInterval, topic

Constructor Summary

Constructors

Constructor	Description
MethodFlowableWorkerEndpoint()

Method Summary

Modifier and Type	Method	Description
protected FlowableWorkerJobListener	createWorkerJobListener(FlowableWorkerContainer container)	Create a FlowableWorkerJobListener that is able to serve this endpoint for the specified container.
Object	getBean()
protected StringBuilder	getEndpointDescription()	Return a description for this endpoint.
Method	getMethod()
void	setBean(Object bean)	Set the actual bean instance to invoke this endpoint method on.
void	setMessageHandlerMethodFactory(org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory messageHandlerMethodFactory)	Set the MessageHandlerMethodFactory to use to build the InvocableHandlerMethod responsible to manage the invocation of this endpoint.
void	setMethod(Method method)	Set the method to invoke for processing a job managed by this endpoint.

Methods inherited from class org.flowable.external.worker.config.AbstractFlowableWorkerEndpoint

getConcurrency, getId, getLockDuration, getNumberOfRetries, getNumberOfTasks, getPollingInterval, getTopic, setConcurrency, setId, setLockDuration, setNumberOfRetries, setNumberOfTasks, setPollingInterval, setTopic, setupFlowableWorkerContainer, setupWorkerContainer, setupWorkerJobListener, toString

Methods inherited from class java.lang.Object

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

Constructor Details

MethodFlowableWorkerEndpoint

public MethodFlowableWorkerEndpoint()

Method Details

setBean

public void setBean(Object bean)

Set the actual bean instance to invoke this endpoint method on.

getBean

public Object getBean()

setMethod

public void setMethod(Method method)

Set the method to invoke for processing a job managed by this endpoint.

getMethod

public Method getMethod()

setMessageHandlerMethodFactory

public void setMessageHandlerMethodFactory(org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory messageHandlerMethodFactory)

Set the MessageHandlerMethodFactory to use to build the InvocableHandlerMethod responsible to manage the invocation of this endpoint.

createWorkerJobListener

protected FlowableWorkerJobListener createWorkerJobListener(FlowableWorkerContainer container)

Description copied from class: AbstractFlowableWorkerEndpoint

Create a FlowableWorkerJobListener that is able to serve this endpoint for the specified container.

Specified by:

createWorkerJobListener in class AbstractFlowableWorkerEndpoint

getEndpointDescription

protected StringBuilder getEndpointDescription()

Description copied from class: AbstractFlowableWorkerEndpoint

Return a description for this endpoint.

Available to subclasses, for inclusion in their toString() result.

Overrides:

getEndpointDescription in class AbstractFlowableWorkerEndpoint