@UriEndpoint(scheme="spark-rest", title="Spark Rest", syntax="spark-rest:verb:path", consumerOnly=true, consumerClass=SparkConsumer.class, label="rest") public class SparkEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
SparkEndpoint(String endpointUri,
org.apache.camel.Component component) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
String |
getAccept() |
String |
getPath() |
SparkBinding |
getSparkBinding() |
SparkConfiguration |
getSparkConfiguration() |
String |
getVerb() |
boolean |
isSingleton() |
void |
setAccept(String accept)
Accept type such as: 'text/xml', or 'application/json'.
|
void |
setPath(String path)
The content path which support Spark syntax.
|
void |
setSparkBinding(SparkBinding sparkBinding)
To use a custom SparkBinding to map to/from Camel message.
|
void |
setSparkConfiguration(SparkConfiguration sparkConfiguration)
To use the SparkConfiguration
|
void |
setVerb(String verb)
get, post, put, patch, delete, head, trace, connect, or options.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, 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 SparkEndpoint(String endpointUri, org.apache.camel.Component component)
public SparkConfiguration getSparkConfiguration()
public void setSparkConfiguration(SparkConfiguration sparkConfiguration)
public SparkBinding getSparkBinding()
public void setSparkBinding(SparkBinding sparkBinding)
public String getVerb()
public void setVerb(String verb)
public String getPath()
public void setPath(String path)
public String getAccept()
public void setAccept(String accept)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
Apache Camel