Package org.apache.camel.impl.engine
Class DefaultReactiveExecutor
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.impl.engine.DefaultReactiveExecutor
-
- All Implemented Interfaces:
AutoCloseable
,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
@ManagedResource(description="Managed ReactiveExecutor") public class DefaultReactiveExecutor extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.spi.ReactiveExecutor, org.apache.camel.StaticService
DefaultReactiveExecutor
.
-
-
Constructor Summary
Constructors Constructor Description DefaultReactiveExecutor()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doStop()
boolean
executeFromQueue()
int
getCreatedWorkers()
int
getPendingTasks()
int
getRunningWorkers()
boolean
isStatisticsEnabled()
static void
onClassloaded(org.slf4j.Logger log)
void
schedule(Runnable runnable)
void
scheduleMain(Runnable runnable)
void
scheduleSync(Runnable runnable)
void
setStatisticsEnabled(boolean statisticsEnabled)
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doStart, 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
-
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
-
isStatisticsEnabled
@ManagedAttribute(description="Whether statistics is enabled") public boolean isStatisticsEnabled()
- Specified by:
isStatisticsEnabled
in interfaceorg.apache.camel.spi.ReactiveExecutor
-
setStatisticsEnabled
public void setStatisticsEnabled(boolean statisticsEnabled)
- Specified by:
setStatisticsEnabled
in interfaceorg.apache.camel.spi.ReactiveExecutor
-
getCreatedWorkers
@ManagedAttribute(description="Number of created workers") public int getCreatedWorkers()
-
getRunningWorkers
@ManagedAttribute(description="Number of running workers") public int getRunningWorkers()
-
getPendingTasks
@ManagedAttribute(description="Number of pending tasks") public int getPendingTasks()
-
onClassloaded
public static void onClassloaded(org.slf4j.Logger log)
-
-