@UriEndpoint(scheme="aws-swf", syntax="aws-swf:type", consumerClass=SWFWorkflowConsumer.class, label="cloud,workflow") public class SWFEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
SWFEndpoint() |
SWFEndpoint(String uri,
SWFComponent component,
SWFConfiguration configuration) |
Modifier and Type | Method and 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.AmazonSimpleWorkflowClient |
getSWClient() |
boolean |
isSingleton() |
void |
setConfiguration(SWFConfiguration configuration) |
void |
setResult(org.apache.camel.Exchange exchange,
Object result) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
public SWFEndpoint()
public SWFEndpoint(String uri, SWFComponent component, SWFConfiguration configuration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
public com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient getSWClient()
public com.amazonaws.services.simpleworkflow.flow.StartWorkflowOptions getStartWorkflowOptions()
public Object getResult(org.apache.camel.Exchange exchange)
public void setResult(org.apache.camel.Exchange exchange, Object result)
public void setConfiguration(SWFConfiguration configuration)
public SWFConfiguration getConfiguration()
Apache Camel