Package akka.camel

Interface Activation

  • All Known Subinterfaces:
    Camel
    All Known Implementing Classes:
    DefaultCamel

    public interface Activation
    Activation trait that can be used to wait on activation or de-activation of Camel endpoints. The Camel endpoints are activated asynchronously. This trait can signal when an endpoint is activated or de-activated.
    • Method Summary

      All Methods Instance Methods Abstract 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.
      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.
    • Method Detail

      • activationFutureFor

        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.

        Parameters:
        endpoint - the endpoint to be activated
        timeout - the timeout for the Future
        executor - (undocumented)
        Returns:
        (undocumented)
      • deactivationFutureFor

        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.

        Parameters:
        endpoint - the endpoint to be deactivated
        timeout - the timeout of the Future
        executor - (undocumented)
        Returns:
        (undocumented)