Package org.apache.camel.reactive.vertx
Class VertXReactiveExecutor
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.reactive.vertx.VertXReactiveExecutor
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.ReactiveExecutor
,org.apache.camel.StatefulService
,org.apache.camel.StaticService
,org.apache.camel.SuspendableService
@JdkService("reactive-executor") public class VertXReactiveExecutor extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.CamelContextAware, org.apache.camel.spi.ReactiveExecutor, org.apache.camel.StaticService
A VertX basedReactiveExecutor
that uses Vert X event loop. NOTE: This is an experimental implementation (use with care)
-
-
Constructor Summary
Constructors Constructor Description VertXReactiveExecutor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doInit()
protected void
doStart()
boolean
executeFromQueue()
org.apache.camel.CamelContext
getCamelContext()
io.vertx.core.Vertx
getVertx()
void
schedule(Runnable runnable)
void
scheduleMain(Runnable runnable)
void
scheduleSync(Runnable runnable)
void
setCamelContext(org.apache.camel.CamelContext camelContext)
void
setVertx(io.vertx.core.Vertx vertx)
To use an existing instance ofVertx
instead of creating a default instance.String
toString()
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doStop, 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, wait, wait, wait
-
-
-
-
Method Detail
-
getCamelContext
public org.apache.camel.CamelContext getCamelContext()
- Specified by:
getCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
setCamelContext
public void setCamelContext(org.apache.camel.CamelContext camelContext)
- Specified by:
setCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
getVertx
public io.vertx.core.Vertx getVertx()
-
setVertx
public void setVertx(io.vertx.core.Vertx vertx)
To use an existing instance ofVertx
instead of creating a default instance.
-
doInit
protected void doInit() throws Exception
- Overrides:
doInit
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
schedule
public void schedule(Runnable runnable)
- Specified by:
schedule
in interfaceorg.apache.camel.spi.ReactiveExecutor
-
scheduleMain
public void scheduleMain(Runnable runnable)
- Specified by:
scheduleMain
in interfaceorg.apache.camel.spi.ReactiveExecutor
-
scheduleSync
public void scheduleSync(Runnable runnable)
- Specified by:
scheduleSync
in interfaceorg.apache.camel.spi.ReactiveExecutor
-
executeFromQueue
public boolean executeFromQueue()
- Specified by:
executeFromQueue
in interfaceorg.apache.camel.spi.ReactiveExecutor
-
-