Class VertxKafkaComponent
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultComponent
-
- org.apache.camel.component.vertx.kafka.VertxKafkaComponent
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Component
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
@Component("vertx-kafka") public class VertxKafkaComponent extends org.apache.camel.support.DefaultComponent
-
-
Constructor Summary
Constructors Constructor Description VertxKafkaComponent()
VertxKafkaComponent(org.apache.camel.CamelContext context)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.camel.Endpoint
createEndpoint(String uri, String remaining, Map<String,Object> parameters)
protected void
doStart()
protected void
doStop()
VertxKafkaConfiguration
getConfiguration()
The component configurationsio.vertx.core.Vertx
getVertx()
io.vertx.core.VertxOptions
getVertxOptions()
void
setConfiguration(VertxKafkaConfiguration configuration)
void
setVertx(io.vertx.core.Vertx vertx)
To use an existing vertx instead of creating a new instancevoid
setVertxOptions(io.vertx.core.VertxOptions vertxOptions)
To provide a custom set of vertx options for configuring vertx-
Methods inherited from class org.apache.camel.support.DefaultComponent
afterConfiguration, createEndpoint, createEndpoint, doBuild, doInit, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getComponentPropertyConfigurer, getEndpointPropertyConfigurer, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, resolveRawParameterValues, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setLazyStartProducer, setProperties, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, 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
-
-
-
-
Method Detail
-
createEndpoint
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
- Specified by:
createEndpoint
in classorg.apache.camel.support.DefaultComponent
- Throws:
Exception
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.DefaultComponent
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.DefaultComponent
- Throws:
Exception
-
getConfiguration
public VertxKafkaConfiguration getConfiguration()
The component configurations
-
setConfiguration
public void setConfiguration(VertxKafkaConfiguration configuration)
-
getVertx
public io.vertx.core.Vertx getVertx()
-
setVertx
public void setVertx(io.vertx.core.Vertx vertx)
To use an existing vertx instead of creating a new instance
-
getVertxOptions
public io.vertx.core.VertxOptions getVertxOptions()
-
setVertxOptions
public void setVertxOptions(io.vertx.core.VertxOptions vertxOptions)
To provide a custom set of vertx options for configuring vertx
-
-