Class SWFEndpoint
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultEndpoint
-
- org.apache.camel.component.aws.swf.SWFEndpoint
-
- All Implemented Interfaces:
AutoCloseable
,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
@UriEndpoint(firstVersion="2.13.0", scheme="aws-swf", title="AWS Simple Workflow (SWF)", syntax="aws-swf:type", category={CLOUD,WORKFLOW}) public class SWFEndpoint extends org.apache.camel.support.DefaultEndpoint
Manage workflows in the AWS Simple Workflow service.
-
-
Constructor Summary
Constructors Constructor Description SWFEndpoint()
SWFEndpoint(String uri, SWFComponent component, SWFConfiguration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.Consumer
createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Exchange
createExchange(Object request, String action)
org.apache.camel.Producer
createProducer()
protected void
doStart()
protected void
doStop()
SWFConfiguration
getConfiguration()
Object
getResult(org.apache.camel.Exchange exchange)
com.amazonaws.services.simpleworkflow.flow.StartWorkflowOptions
getStartWorkflowOptions()
com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflow
getSWClient()
void
setConfiguration(SWFConfiguration configuration)
void
setResult(org.apache.camel.Exchange exchange, Object result)
-
Methods inherited from class org.apache.camel.support.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isSingleton, isSynchronous, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, 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
-
-
-
-
Constructor Detail
-
SWFEndpoint
public SWFEndpoint()
-
SWFEndpoint
public SWFEndpoint(String uri, SWFComponent component, SWFConfiguration configuration)
-
-
Method Detail
-
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
- Throws:
Exception
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.DefaultEndpoint
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.DefaultEndpoint
- Throws:
Exception
-
getSWClient
public com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflow getSWClient()
-
getStartWorkflowOptions
public com.amazonaws.services.simpleworkflow.flow.StartWorkflowOptions getStartWorkflowOptions()
-
getResult
public Object getResult(org.apache.camel.Exchange exchange)
-
setResult
public void setResult(org.apache.camel.Exchange exchange, Object result)
-
setConfiguration
public void setConfiguration(SWFConfiguration configuration)
-
getConfiguration
public SWFConfiguration getConfiguration()
-
-