akka.camel
Class ActorRouteDefinition<T extends >

java.lang.Object
  extended by 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


Constructor Summary
ActorRouteDefinition( 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
 

Constructor Detail

ActorRouteDefinition

public ActorRouteDefinition( definition)
Method Detail

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 consumer
autoAck - 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