Package akka.camel.internal

Class DefaultCamel

  • All Implemented Interfaces:
    Extension, Activation, Camel
    public class DefaultCamel
extends java.lang.Object
implements Camel
    Starts camel and underlying camel context and template. Only the creator of Camel should start and stop it.
    See Also:
    shutdown()

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      scala.concurrent.Future<ActorRef> activationFutureFor​(ActorRef endpoint, Timeout timeout, scala.concurrent.ExecutionContext executor)
      Produces a Future with the specified endpoint that will be completed when the endpoint has been activated, or if it times out, which will happen after the specified Timeout.
      org.apache.camel.impl.DefaultCamelContext context()  
      scala.concurrent.Future<ActorRef> deactivationFutureFor​(ActorRef endpoint, Timeout timeout, scala.concurrent.ExecutionContext executor)
      Produces a Future which will be completed when the given endpoint has been deactivated or or if it times out, which will happen after the specified Timeout.
      LoggingAdapter log()  
      CamelSettings settings()
      The settings for the CamelExtension
      void shutdown()
      Stops camel and underlying camel context and template.
      DefaultCamel start()
      Starts camel and underlying camel context and template.
      ActorRef supervisor()
      INTERNAL API Returns the camel supervisor actor.
      ExtendedActorSystem system()
      INTERNAL API Returns the associated ActorSystem.
      org.apache.camel.ProducerTemplate template()
      The Camel ProducerTemplate.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • activationFutureFor

        public scala.concurrent.Future<ActorRef> activationFutureFor​(ActorRef endpoint,
                                                             Timeout timeout,
                                                             scala.concurrent.ExecutionContext executor)
        Produces a Future with the specified endpoint that will be completed when the endpoint has been activated, or if it times out, which will happen after the specified Timeout.

        Specified by:
        activationFutureFor in interface Activation
        Parameters:
        endpoint - the endpoint to be activated
        timeout - the timeout for the Future
        executor - (undocumented)
        Returns:
        (undocumented)

      • context

        public org.apache.camel.impl.DefaultCamelContext context()
        Specified by:
        context in interface Camel

      • deactivationFutureFor

        public scala.concurrent.Future<ActorRef> deactivationFutureFor​(ActorRef endpoint,
                                                               Timeout timeout,
                                                               scala.concurrent.ExecutionContext executor)
        Produces a Future which will be completed when the given endpoint has been deactivated or or if it times out, which will happen after the specified Timeout.

        Specified by:
        deactivationFutureFor in interface Activation
        Parameters:
        endpoint - the endpoint to be deactivated
        timeout - the timeout of the Future
        executor - (undocumented)
        Returns:
        (undocumented)

      • settings

        public CamelSettings settings()
        Description copied from interface: Camel
        The settings for the CamelExtension
        Specified by:
        settings in interface Camel
        Returns:
        (undocumented)

      • shutdown

        public void shutdown()
        Stops camel and underlying camel context and template. Only the creator of Camel should shut it down. There is no need to stop Camel instance, which you get from the CamelExtension, as its lifecycle is bound to the actor system.

        See Also:
        start()

      • start

        public DefaultCamel start()
        Starts camel and underlying camel context and template. Only the creator of Camel should start and stop it.
        Returns:
        (undocumented)
        See Also:
        shutdown()

      • supervisor

        public ActorRef supervisor()
        Description copied from interface: Camel
        INTERNAL API Returns the camel supervisor actor.
        Specified by:
        supervisor in interface Camel
        Returns:
        (undocumented)

      • system

        public ExtendedActorSystem system()
        Description copied from interface: Camel
        INTERNAL API Returns the associated ActorSystem.
        Specified by:
        system in interface Camel
        Returns:
        (undocumented)

      • template

        public org.apache.camel.ProducerTemplate template()
        Description copied from interface: Camel
        The Camel ProducerTemplate.
        Specified by:
        template in interface Camel
        Returns:
        (undocumented)
        See Also:
        ProducerTemplate