org.apache.camel.component.sparkrest

Class SparkComponent

java.lang.Object

org.apache.camel.support.service.ServiceSupport

org.apache.camel.support.DefaultComponent

org.apache.camel.component.sparkrest.SparkComponent

All Implemented Interfaces:

AutoCloseable, org.apache.camel.CamelContextAware, org.apache.camel.Component, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.RestApiConsumerFactory, org.apache.camel.spi.RestConsumerFactory, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

@Component(value="spark-rest")
public class SparkComponent
extends org.apache.camel.support.DefaultComponent
implements org.apache.camel.spi.RestConsumerFactory, org.apache.camel.spi.RestApiConsumerFactory

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
SparkComponent()

Method Summary

Modifier and Type	Method and Description
org.apache.camel.Consumer	createApiConsumer(org.apache.camel.CamelContext camelContext, org.apache.camel.Processor processor, String contextPath, org.apache.camel.spi.RestConfiguration configuration, Map<String,Object> parameters)
org.apache.camel.Consumer	createConsumer(org.apache.camel.CamelContext camelContext, org.apache.camel.Processor processor, String verb, String basePath, String uriTemplate, String consumes, String produces, org.apache.camel.spi.RestConfiguration configuration, Map<String,Object> parameters)
protected org.apache.camel.Endpoint	createEndpoint(String uri, String remaining, Map<String,Object> parameters)
protected void	doShutdown()
protected void	doStart()
String	getIpAddress()
String	getKeystoreFile()
String	getKeystorePassword()
int	getMaxThreads()
int	getMinThreads()
int	getPort()
SparkBinding	getSparkBinding()
SparkConfiguration	getSparkConfiguration()
spark.Service	getSparkInstance()
int	getTimeOutMillis()
String	getTruststoreFile()
String	getTruststorePassword()
void	setIpAddress(String ipAddress) Set the IP address that Spark should listen on.
void	setKeystoreFile(String keystoreFile) Configures connection to be secure to use the keystore file
void	setKeystorePassword(String keystorePassword) Configures connection to be secure to use the keystore password
void	setMaxThreads(int maxThreads) Maximum number of threads in Spark thread-pool (shared globally)
void	setMinThreads(int minThreads) Minimum number of threads in Spark thread-pool (shared globally)
void	setPort(int port) Port number.
void	setSparkBinding(SparkBinding sparkBinding) To use a custom SparkBinding to map to/from Camel message.
void	setSparkConfiguration(SparkConfiguration sparkConfiguration) To use the shared SparkConfiguration
void	setTimeOutMillis(int timeOutMillis) Thread idle timeout in millis where threads that has been idle for a longer period will be terminated from the thread pool
void	setTruststoreFile(String truststoreFile) Configures connection to be secure to use the truststore file
void	setTruststorePassword(String truststorePassword) Configures connection to be secure to use the truststore password

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

afterConfiguration, createEndpoint, createEndpoint, doInit, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getComponentPropertyConfigurer, getEndpointPropertyConfigurer, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isBasicPropertyBinding, isBridgeErrorHandler, isLazyStartProducer, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setBasicPropertyBinding, setBridgeErrorHandler, setCamelContext, setLazyStartProducer, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI

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

build, doBuild, doResume, 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, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.camel.Component

trySetComponent

Methods inherited from interface org.apache.camel.CamelContextAware

trySetCamelContext

Methods inherited from interface org.apache.camel.Service

build, close, init, start, stop

Constructor Detail

SparkComponent

public SparkComponent()

Method Detail

getSparkInstance

public spark.Service getSparkInstance()

getPort

public int getPort()

setPort

public void setPort(int port)

Port number.

Will by default use 4567

getIpAddress

public String getIpAddress()

setIpAddress

public void setIpAddress(String ipAddress)

Set the IP address that Spark should listen on. If not called the default address is '0.0.0.0'.

getMinThreads

public int getMinThreads()

setMinThreads

public void setMinThreads(int minThreads)

Minimum number of threads in Spark thread-pool (shared globally)

getMaxThreads

public int getMaxThreads()

setMaxThreads

public void setMaxThreads(int maxThreads)

Maximum number of threads in Spark thread-pool (shared globally)

getTimeOutMillis

public int getTimeOutMillis()

setTimeOutMillis

public void setTimeOutMillis(int timeOutMillis)

Thread idle timeout in millis where threads that has been idle for a longer period will be terminated from the thread pool

getKeystoreFile

public String getKeystoreFile()

setKeystoreFile

public void setKeystoreFile(String keystoreFile)

Configures connection to be secure to use the keystore file

getKeystorePassword

public String getKeystorePassword()

setKeystorePassword

public void setKeystorePassword(String keystorePassword)

Configures connection to be secure to use the keystore password

getTruststoreFile

public String getTruststoreFile()

setTruststoreFile

public void setTruststoreFile(String truststoreFile)

Configures connection to be secure to use the truststore file

getTruststorePassword

public String getTruststorePassword()

setTruststorePassword

public void setTruststorePassword(String truststorePassword)

Configures connection to be secure to use the truststore password

getSparkConfiguration

public SparkConfiguration getSparkConfiguration()

setSparkConfiguration

public void setSparkConfiguration(SparkConfiguration sparkConfiguration)

To use the shared SparkConfiguration

getSparkBinding

public SparkBinding getSparkBinding()

setSparkBinding

public void setSparkBinding(SparkBinding sparkBinding)

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

createEndpoint

protected org.apache.camel.Endpoint createEndpoint(String uri,
                                                   String remaining,
                                                   Map<String,Object> parameters)
                                            throws Exception

Specified by:

createEndpoint in class org.apache.camel.support.DefaultComponent

Throws:

Exception

doStart

protected void doStart()
                throws Exception

Overrides:

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

Throws:

Exception

doShutdown

protected void doShutdown()
                   throws Exception

Overrides:

doShutdown in class org.apache.camel.support.service.ServiceSupport

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.CamelContext camelContext,
                                                org.apache.camel.Processor processor,
                                                String verb,
                                                String basePath,
                                                String uriTemplate,
                                                String consumes,
                                                String produces,
                                                org.apache.camel.spi.RestConfiguration configuration,
                                                Map<String,Object> parameters)
                                         throws Exception

Specified by:

createConsumer in interface org.apache.camel.spi.RestConsumerFactory

Throws:

Exception

createApiConsumer

public org.apache.camel.Consumer createApiConsumer(org.apache.camel.CamelContext camelContext,
                                                   org.apache.camel.Processor processor,
                                                   String contextPath,
                                                   org.apache.camel.spi.RestConfiguration configuration,
                                                   Map<String,Object> parameters)
                                            throws Exception

Specified by:

createApiConsumer in interface org.apache.camel.spi.RestApiConsumerFactory

Throws:

Exception