org.flowable.camel

Class FlowableProducer

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultProducer

org.flowable.camel.FlowableProducer

All Implemented Interfaces:

org.apache.camel.EndpointAware, org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class FlowableProducer
extends org.apache.camel.impl.DefaultProducer

Author:

Saeid Mirzaei, Maciej Próchniak, Arnold Schrijver

Field Summary

Fields

Modifier and Type	Field and Description
static String	EXECUTION_ID_PROPERTY
protected IdentityService	identityService
protected ManagementService	managementService
static String	PROCESS_ID_PROPERTY
static String	PROCESS_KEY_PROPERTY
protected RepositoryService	repositoryService
protected RuntimeService	runtimeService

Fields inherited from class org.apache.camel.impl.DefaultProducer

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
FlowableProducer(FlowableEndpoint endpoint, long timeout, long timeResolution)

Method Summary

Modifier and Type	Method and Description
protected void	copyResultToCamel(org.apache.camel.Exchange exchange, ProcessInstance pi)
protected String	findProcessInstanceId(org.apache.camel.Exchange exchange)
protected FlowableEndpoint	getFlowableEndpoint()
void	process(org.apache.camel.Exchange exchange)
void	setIdentityService(IdentityService identityService)
void	setManagementService(ManagementService managementService)
protected void	setProcessInitiator(String processInitiator)
void	setRepositoryService(RepositoryService repositoryService)
void	setRuntimeService(RuntimeService runtimeService)
protected boolean	shouldStartProcess()
protected void	signal(org.apache.camel.Exchange exchange)
protected ProcessInstance	startProcess(org.apache.camel.Exchange exchange)

Methods inherited from class org.apache.camel.impl.DefaultProducer

createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.camel.Service

start, stop

Field Detail

identityService

protected IdentityService identityService

runtimeService

protected RuntimeService runtimeService

repositoryService

protected RepositoryService repositoryService

managementService

protected ManagementService managementService

PROCESS_KEY_PROPERTY

public static final String PROCESS_KEY_PROPERTY

See Also:

Constant Field Values

PROCESS_ID_PROPERTY

public static final String PROCESS_ID_PROPERTY

See Also:

Constant Field Values

EXECUTION_ID_PROPERTY

public static final String EXECUTION_ID_PROPERTY

See Also:

Constant Field Values

Constructor Detail

FlowableProducer

public FlowableProducer(FlowableEndpoint endpoint,
                        long timeout,
                        long timeResolution)

Method Detail

process

public void process(org.apache.camel.Exchange exchange)
             throws Exception

Throws:

Exception

copyResultToCamel

protected void copyResultToCamel(org.apache.camel.Exchange exchange,
                                 ProcessInstance pi)

shouldStartProcess

protected boolean shouldStartProcess()

signal

protected void signal(org.apache.camel.Exchange exchange)

findProcessInstanceId

protected String findProcessInstanceId(org.apache.camel.Exchange exchange)

startProcess

protected ProcessInstance startProcess(org.apache.camel.Exchange exchange)

setProcessInitiator

protected void setProcessInitiator(String processInitiator)

getFlowableEndpoint

protected FlowableEndpoint getFlowableEndpoint()

setIdentityService

public void setIdentityService(IdentityService identityService)

setRuntimeService

public void setRuntimeService(RuntimeService runtimeService)

setRepositoryService

public void setRepositoryService(RepositoryService repositoryService)

setManagementService

public void setManagementService(ManagementService managementService)