Package org.apache.camel.component.vertx
Class VertxComponent
- 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.VertxComponent
-
- 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") public class VertxComponent extends org.apache.camel.support.DefaultComponent
-
-
Constructor Summary
Constructors Constructor Description VertxComponent()
VertxComponent(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()
String
getHost()
int
getPort()
int
getTimeout()
io.vertx.core.Vertx
getVertx()
io.vertx.core.spi.VertxFactory
getVertxFactory()
io.vertx.core.VertxOptions
getVertxOptions()
void
setHost(String host)
Hostname for creating an embedded clustered EventBusvoid
setPort(int port)
Port for creating an embedded clustered EventBusvoid
setTimeout(int timeout)
Timeout in seconds to wait for clustered Vertx EventBus to be ready.void
setVertx(io.vertx.core.Vertx vertx)
To use the given vertx EventBus instead of creating a new embedded EventBusvoid
setVertxFactory(io.vertx.core.spi.VertxFactory vertxFactory)
To use a custom VertxFactory implementationvoid
setVertxOptions(io.vertx.core.VertxOptions vertxOptions)
Options to use for creating 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
-
getVertxFactory
public io.vertx.core.spi.VertxFactory getVertxFactory()
-
setVertxFactory
public void setVertxFactory(io.vertx.core.spi.VertxFactory vertxFactory)
To use a custom VertxFactory implementation
-
getHost
public String getHost()
-
setHost
public void setHost(String host)
Hostname for creating an embedded clustered EventBus
-
getPort
public int getPort()
-
setPort
public void setPort(int port)
Port for creating an embedded clustered EventBus
-
getVertxOptions
public io.vertx.core.VertxOptions getVertxOptions()
-
setVertxOptions
public void setVertxOptions(io.vertx.core.VertxOptions vertxOptions)
Options to use for creating vertx
-
getVertx
public io.vertx.core.Vertx getVertx()
-
setVertx
public void setVertx(io.vertx.core.Vertx vertx)
To use the given vertx EventBus instead of creating a new embedded EventBus
-
getTimeout
public int getTimeout()
-
setTimeout
public void setTimeout(int timeout)
Timeout in seconds to wait for clustered Vertx EventBus to be ready. The default value is 60.
-
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
-
-