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

Modifier and Type	Method and 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)