org.flowable.camel

Class FlowableEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.flowable.camel.FlowableEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class FlowableEndpoint
extends org.apache.camel.impl.DefaultEndpoint

This class has been modified to be consistent with the changes to CamelBehavior and its implementations. The set of changes significantly increases the flexibility of our Camel integration, as you can either choose one of three "out-of-the-box" modes, or you can choose to create your own. Please reference the comments for the "CamelBehavior" class for more information on the out-of-the-box implementation class options.

Author:

Ryan Johnston (@rjfsu), Tijs Rademakers, Arnold Schrijver

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	copyCamelBodyToBody
protected boolean	copyCamelBodyToBodyAsString
protected String	copyVariablesFromHeader
protected String	copyVariablesFromProperties
protected boolean	copyVariablesToBodyAsMap
protected boolean	copyVariablesToProperties
protected FlowableConsumer	flowableConsumer
protected IdentityService	identityService
protected ManagementService	managementService
protected String	processInitiatorHeaderName
protected RepositoryService	repositoryService
protected Map<String,Object>	returnVarMap
protected RuntimeService	runtimeService
protected long	timeout
protected int	timeResolution

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

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

Constructor Summary

Constructors

Constructor and Description
FlowableEndpoint(String uri, org.apache.camel.CamelContext camelContext)

Method Summary

Modifier and Type	Method and Description
protected void	addConsumer(FlowableConsumer consumer)
org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
String	getCopyVariablesFromHeader()
String	getCopyVariablesFromProperties()
String	getProcessInitiatorHeaderName()
Map<String,Object>	getReturnVarMap()
long	getTimeout()
int	getTimeResolution()
boolean	isCopyCamelBodyToBody()
boolean	isCopyCamelBodyToBodyAsString()
boolean	isCopyVariablesToBodyAsMap()
boolean	isCopyVariablesToProperties()
boolean	isLenientProperties()
boolean	isSetProcessInitiator()
boolean	isSingleton()
void	process(org.apache.camel.Exchange ex)
protected void	removeConsumer()
void	setCopyCamelBodyToBody(boolean copyCamelBodyToBody)
void	setCopyCamelBodyToBodyAsString(boolean copyCamelBodyToBodyAsString)
void	setCopyVariablesFromHeader(String copyVariablesFromHeader)
void	setCopyVariablesFromProperties(String copyVariablesFromProperties)
void	setCopyVariablesToBodyAsMap(boolean copyVariablesToBodyAsMap)
void	setCopyVariablesToProperties(boolean copyVariablesToProperties)
void	setIdentityService(IdentityService identityService)
void	setManagementService(ManagementService managementService)
void	setProcessInitiatorHeaderName(String processInitiatorHeaderName)
void	setRepositoryService(RepositoryService repositoryService)
void	setReturnVarMap(Map<String,Object> returnVarMap)
void	setRuntimeService(RuntimeService runtimeService)

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

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, 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, finalize, getClass, 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

flowableConsumer

protected FlowableConsumer flowableConsumer

copyVariablesToProperties

protected boolean copyVariablesToProperties

copyVariablesToBodyAsMap

protected boolean copyVariablesToBodyAsMap

copyCamelBodyToBody

protected boolean copyCamelBodyToBody

copyVariablesFromProperties

protected String copyVariablesFromProperties

copyVariablesFromHeader

protected String copyVariablesFromHeader

copyCamelBodyToBodyAsString

protected boolean copyCamelBodyToBodyAsString

processInitiatorHeaderName

protected String processInitiatorHeaderName

returnVarMap

protected Map<String,Object> returnVarMap

timeout

protected long timeout

timeResolution

protected int timeResolution

Constructor Detail

FlowableEndpoint

public FlowableEndpoint(String uri,
                        org.apache.camel.CamelContext camelContext)

Method Detail

process

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

Throws:

Exception

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Throws:

Exception

addConsumer

protected void addConsumer(FlowableConsumer consumer)

removeConsumer

protected void removeConsumer()

isSingleton

public boolean isSingleton()

setIdentityService

public void setIdentityService(IdentityService identityService)

setRuntimeService

public void setRuntimeService(RuntimeService runtimeService)

setRepositoryService

public void setRepositoryService(RepositoryService repositoryService)

setManagementService

public void setManagementService(ManagementService managementService)

isCopyVariablesToProperties

public boolean isCopyVariablesToProperties()

setCopyVariablesToProperties

public void setCopyVariablesToProperties(boolean copyVariablesToProperties)

isCopyCamelBodyToBody

public boolean isCopyCamelBodyToBody()

setCopyCamelBodyToBody

public void setCopyCamelBodyToBody(boolean copyCamelBodyToBody)

isCopyVariablesToBodyAsMap

public boolean isCopyVariablesToBodyAsMap()

setCopyVariablesToBodyAsMap

public void setCopyVariablesToBodyAsMap(boolean copyVariablesToBodyAsMap)

getCopyVariablesFromProperties

public String getCopyVariablesFromProperties()

setCopyVariablesFromProperties

public void setCopyVariablesFromProperties(String copyVariablesFromProperties)

getCopyVariablesFromHeader

public String getCopyVariablesFromHeader()

setCopyVariablesFromHeader

public void setCopyVariablesFromHeader(String copyVariablesFromHeader)

isCopyCamelBodyToBodyAsString

public boolean isCopyCamelBodyToBodyAsString()

setCopyCamelBodyToBodyAsString

public void setCopyCamelBodyToBodyAsString(boolean copyCamelBodyToBodyAsString)

isSetProcessInitiator

public boolean isSetProcessInitiator()

getReturnVarMap

public Map<String,Object> getReturnVarMap()

setReturnVarMap

public void setReturnVarMap(Map<String,Object> returnVarMap)

getProcessInitiatorHeaderName

public String getProcessInitiatorHeaderName()

setProcessInitiatorHeaderName

public void setProcessInitiatorHeaderName(String processInitiatorHeaderName)

isLenientProperties

public boolean isLenientProperties()

Specified by:

isLenientProperties in interface org.apache.camel.Endpoint

Overrides:

isLenientProperties in class org.apache.camel.impl.DefaultEndpoint

getTimeout

public long getTimeout()

getTimeResolution

public int getTimeResolution()