Class 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
    Default ReactiveExecutor.
    • Field Summary

      • Fields inherited from class org.apache.camel.support.service.BaseService

        BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING
      • Fields inherited from interface org.apache.camel.spi.ReactiveExecutor

        FACTORY
    • Constructor Detail

      • DefaultReactiveExecutor

        public DefaultReactiveExecutor()
    • Method Detail

      • schedule

        public void schedule​(Runnable runnable)
        Specified by:
        schedule in interface org.apache.camel.spi.ReactiveExecutor
      • scheduleMain

        public void scheduleMain​(Runnable runnable)
        Specified by:
        scheduleMain in interface org.apache.camel.spi.ReactiveExecutor
      • scheduleSync

        public void scheduleSync​(Runnable runnable)
        Specified by:
        scheduleSync in interface org.apache.camel.spi.ReactiveExecutor
      • executeFromQueue

        public boolean executeFromQueue()
        Specified by:
        executeFromQueue in interface org.apache.camel.spi.ReactiveExecutor
      • isStatisticsEnabled

        @ManagedAttribute(description="Whether statistics is enabled")
        public boolean isStatisticsEnabled()
        Specified by:
        isStatisticsEnabled in interface org.apache.camel.spi.ReactiveExecutor
      • setStatisticsEnabled

        public void setStatisticsEnabled​(boolean statisticsEnabled)
        Specified by:
        setStatisticsEnabled in interface org.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)
      • doStop

        protected void doStop()
                       throws Exception
        Overrides:
        doStop in class org.apache.camel.support.service.BaseService
        Throws:
        Exception