@UriEndpoint(scheme="aws-swf", title="AWS Simple Workflow", syntax="aws-swf:type", consumerClass=SWFWorkflowConsumer.class, label="cloud,workflow") public class SWFEndpoint extends DefaultEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
Constructor and Description |
---|
SWFEndpoint() |
SWFEndpoint(String uri,
SWFComponent component,
SWFConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
Exchange |
createExchange(Object request,
String action) |
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
protected void |
doStart()
Implementations override this method to support customized start/stop.
|
protected void |
doStop()
Implementations override this method to support customized start/stop.
|
SWFConfiguration |
getConfiguration() |
Object |
getResult(Exchange exchange) |
com.amazonaws.services.simpleworkflow.flow.StartWorkflowOptions |
getStartWorkflowOptions() |
com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient |
getSWClient() |
boolean |
isSingleton()
Whether this class supports being singleton or not.
|
void |
setConfiguration(SWFConfiguration configuration) |
void |
setResult(Exchange exchange,
Object result) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public SWFEndpoint()
public SWFEndpoint(String uri, SWFComponent component, SWFConfiguration configuration)
public Producer createProducer() throws Exception
Endpoint
Exception
- can be thrownpublic Consumer createConsumer(Processor processor) throws Exception
Endpoint
processor
- the given processorException
- can be thrownpublic boolean isSingleton()
IsSingleton
protected void doStart() throws Exception
ServiceSupport
ServiceSupport.doStop()
for more details.doStart
in class DefaultEndpoint
Exception
ServiceSupport.doStop()
protected void doStop() throws Exception
ServiceSupport
ServiceSupport.doStop()
method when
the service is being stopped. This method will also be invoked
if the service is still in uninitialized state (eg has not
been started). The method is always called to allow the service
to do custom logic when the service is being stopped, such as when
CamelContext
is shutting down.doStop
in class DefaultEndpoint
Exception
ServiceSupport.doStart()
public com.amazonaws.services.simpleworkflow.AmazonSimpleWorkflowClient getSWClient()
public com.amazonaws.services.simpleworkflow.flow.StartWorkflowOptions getStartWorkflowOptions()
public void setConfiguration(SWFConfiguration configuration)
public SWFConfiguration getConfiguration()
Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.