Class ClusteredRouteController

  • All Implemented Interfaces:
    AutoCloseable, org.apache.camel.CamelContextAware, org.apache.camel.NonManagedService, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.RouteController, org.apache.camel.StatefulService, org.apache.camel.StaticService, org.apache.camel.SuspendableService

    public class ClusteredRouteController
    extends org.apache.camel.impl.engine.DefaultRouteController
    Clustered RouteController.
    • 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
    • Constructor Detail

      • ClusteredRouteController

        public ClusteredRouteController()
    • Method Detail

      • addFilter

        public void addFilter​(ClusteredRouteFilter filter)
        Add a filter used to to filter cluster aware routes.
      • getInitialDelay

        public Duration getInitialDelay()
      • setInitialDelay

        public void setInitialDelay​(Duration initialDelay)
        Set the amount of time the route controller should wait before to start the routes after the camel context is started.
        Parameters:
        initialDelay - the initial delay.
      • getNamespace

        public String getNamespace()
      • setNamespace

        public void setNamespace​(String namespace)
        Set the default namespace.
      • getClusterService

        public org.apache.camel.cluster.CamelClusterService getClusterService()
      • setClusterService

        public void setClusterService​(org.apache.camel.cluster.CamelClusterService clusterService)
        Set the cluster service to use.
      • getClusterServiceSelector

        public org.apache.camel.cluster.CamelClusterService.Selector getClusterServiceSelector()
      • setClusterServiceSelector

        public void setClusterServiceSelector​(org.apache.camel.cluster.CamelClusterService.Selector clusterServiceSelector)
        Set the selector strategy to look-up a CamelClusterService
      • getControlledRoutes

        public Collection<org.apache.camel.Route> getControlledRoutes()
        Specified by:
        getControlledRoutes in interface org.apache.camel.spi.RouteController
        Overrides:
        getControlledRoutes in class org.apache.camel.impl.engine.DefaultRouteController
      • doStart

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

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

        public void setCamelContext​(org.apache.camel.CamelContext camelContext)
        Specified by:
        setCamelContext in interface org.apache.camel.CamelContextAware
        Overrides:
        setCamelContext in class org.apache.camel.impl.engine.DefaultRouteController