class ActorRouteDefinition[T <: ProcessorDefinition[T]] extends AnyRef
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 akka.actor.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) } }
- Alphabetic
- By Inheritance
- ActorRouteDefinition
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
ActorRouteDefinition(definition: ProcessorDefinition[T])
- definition
the processor definition
Value Members
-
def
to(actorRef: ActorRef, autoAck: Boolean, replyTimeout: Duration): T
Sends the message to an ActorRef endpoint
Sends the message to an ActorRef endpoint
- 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
-
def
to(actorRef: ActorRef): T
Sends the message to an ActorRef endpoint.
Sends the message to an ActorRef endpoint.
- actorRef
the actorRef to the actor.
- returns
the path to the actor, as a camel uri String