akka.camel
Class ActorRouteDefinition<T extends >
java.lang.Object
akka.camel.ActorRouteDefinition<T>
public class ActorRouteDefinition<T extends >
- extends java.lang.Object
Wraps a org.apache.camel.model.ProcessorDefinition
.
There is an implicit conversion in the akka.camel
package object that converts a ProcessorDefinition
into this
type.
Because of this conversion, it is possible to use an ActorRef
as a to
parameter in building a route:
class TestRoute(system: ActorSystem) extends RouteBuilder {
val responder = system.actorOf(Props[TestResponder], name = "TestResponder")
def configure {
from("direct:producer").to(responder)
}
}
param: definition the processor definition
Method Summary |
T |
to(ActorRef actorRef)
Sends the message to an ActorRef endpoint. |
T |
to(ActorRef actorRef,
boolean autoAck,
scala.concurrent.duration.Duration replyTimeout)
Sends the message to an ActorRef endpoint |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ActorRouteDefinition
public ActorRouteDefinition( definition)
to
public T to(ActorRef actorRef)
- Sends the message to an ActorRef endpoint.
- Parameters:
actorRef
- the actorRef to the actor.
- Returns:
- the path to the actor, as a camel uri String
to
public T to(ActorRef actorRef,
boolean autoAck,
scala.concurrent.duration.Duration replyTimeout)
- Sends the message to an ActorRef endpoint
- Parameters:
actorRef
- the consumerautoAck
- Determines whether one-way communications between an endpoint and this consumer actor
should be auto-acknowledged or application-acknowledged.
This flag has only effect when exchange is in-only.replyTimeout
- When endpoint is out-capable (can produce responses) replyTimeout is the maximum time
the endpoint can take to send the response before the message exchange fails. It defaults to 1 minute.
This setting is used for out-capable, in-only, manually acknowledged communication.
- Returns:
- the path to the actor, as a camel uri String