org.apache.camel.component.sparkrest

Class SparkEndpoint

java.lang.Object

org.apache.camel.support.service.ServiceSupport

org.apache.camel.support.DefaultEndpoint

org.apache.camel.component.sparkrest.SparkEndpoint

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.14.0",
             scheme="spark-rest",
             title="Spark Rest",
             syntax="spark-rest:verb:path",
             consumerOnly=true,
             label="rest")
public class SparkEndpoint
extends org.apache.camel.support.DefaultEndpoint

The spark-rest component is used for hosting REST services which has been defined using Camel rest-dsl.

Field Summary

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

BUILDED, FAILED, INITIALIZED, lock, log, NEW, SHUTDOWN, SHUTTINGDOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING

Constructor Summary

Constructors

Constructor and Description
SparkEndpoint(String endpointUri, org.apache.camel.Component component)

Method Summary

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()
SparkComponent	getComponent()
String	getPath()
SparkBinding	getSparkBinding()
SparkConfiguration	getSparkConfiguration()
String	getVerb()
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.

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

configureConsumer, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStop, equals, getCamelContext, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBasicPropertyBinding, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isSingleton, isSynchronous, setBasicPropertyBinding, setBridgeErrorHandler, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.service.ServiceSupport

build, doBuild, doResume, doShutdown, doSuspend, 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

Methods inherited from interface org.apache.camel.Service

build, close, init, start, stop

Methods inherited from interface org.apache.camel.CamelContextAware

trySetCamelContext

Constructor Detail

SparkEndpoint

public SparkEndpoint(String endpointUri,
                     org.apache.camel.Component component)

Method Detail

getSparkConfiguration

public SparkConfiguration getSparkConfiguration()

setSparkConfiguration

public void setSparkConfiguration(SparkConfiguration sparkConfiguration)

To use the SparkConfiguration

getSparkBinding

public SparkBinding getSparkBinding()

setSparkBinding

public void setSparkBinding(SparkBinding sparkBinding)

To use a custom SparkBinding to map to/from Camel message.

getVerb

public String getVerb()

setVerb

public void setVerb(String verb)

get, post, put, patch, delete, head, trace, connect, or options.

getPath

public String getPath()

setPath

public void setPath(String path)

The content path which support Spark syntax.

getAccept

public String getAccept()

setAccept

public void setAccept(String accept)

Accept type such as: 'text/xml', or 'application/json'. By default we accept all kinds of types.

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

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.apache.camel.support.DefaultEndpoint

Throws:

Exception

getComponent

public SparkComponent getComponent()

Overrides:

getComponent in class org.apache.camel.support.DefaultEndpoint