org.apache.camel.component.sparkrest

Class SparkConsumer

java.lang.Object

org.apache.camel.support.service.ServiceSupport

org.apache.camel.support.DefaultConsumer

org.apache.camel.component.sparkrest.SparkConsumer

All Implemented Interfaces:

AutoCloseable, org.apache.camel.Consumer, org.apache.camel.EndpointAware, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class SparkConsumer
extends org.apache.camel.support.DefaultConsumer

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
SparkConsumer(org.apache.camel.Endpoint endpoint, org.apache.camel.Processor processor, CamelSparkRoute route)

Method Summary

Modifier and Type	Method and Description
protected void	doStart()
SparkEndpoint	getEndpoint()
boolean	isEnableCors()
void	setEnableCors(boolean enableCors)

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

createUoW, doInit, doneUoW, doStop, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, 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, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

build, close, init, start, stop

Constructor Detail

SparkConsumer

public SparkConsumer(org.apache.camel.Endpoint endpoint,
                     org.apache.camel.Processor processor,
                     CamelSparkRoute route)

Method Detail

getEndpoint

public SparkEndpoint getEndpoint()

Specified by:

getEndpoint in interface org.apache.camel.EndpointAware

Overrides:

getEndpoint in class org.apache.camel.support.DefaultConsumer

isEnableCors

public boolean isEnableCors()

setEnableCors

public void setEnableCors(boolean enableCors)

doStart

protected void doStart()
                throws Exception

Overrides:

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

Throws:

Exception