package camel
- Alphabetic
- By Inheritance
- camel
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
trait
Activation extends AnyRef
Activation trait that can be used to wait on activation or de-activation of Camel endpoints.
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.
-
class
ActorNotRegisteredException extends RuntimeException
Thrown to indicate that the actor referenced by an endpoint URI cannot be found in the actor system.
-
class
ActorRouteDefinition[T <: ProcessorDefinition[T]] extends AnyRef
Wraps a org.apache.camel.model.ProcessorDefinition.
Wraps a org.apache.camel.model.ProcessorDefinition. There is an implicit conversion in the
akka.camel
package object that converts aProcessorDefinition
intothis
type. Because of this conversion, it is possible to use an akka.actor.ActorRef as ato
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) } }
-
class
AkkaCamelException extends AkkaException
An exception indicating that the exchange to the camel endpoint failed.
An exception indicating that the exchange to the camel endpoint failed. It contains the failure cause obtained from Exchange.getException and the headers from either the Exchange.getIn message or Exchange.getOut message, depending on the exchange pattern.
-
trait
Camel extends Extension with Activation
Camel trait encapsulates the underlying camel machinery.
Camel trait encapsulates the underlying camel machinery. Note:
CamelContext
andProducerTemplate
are stopped when the associated actor system is shut down. This trait can be obtained through the akka.camel.CamelExtension object. -
class
CamelSettings extends AnyRef
Settings for the Camel Extension
-
trait
ContextProvider extends AnyRef
Implement this interface in order to inject a specific CamelContext in a system An instance of this class must be instantiable using a no-arg constructor.
-
final
class
DefaultContextProvider extends ContextProvider
Default implementation of akka.camel.ContextProvider Provides a new DefaultCamelContext per actor system
-
trait
ProducerSupport extends Actor with CamelSupport
Support trait for producing messages to Camel endpoints.
-
class
CamelMessage extends Serializable with Product
An immutable representation of a Camel message.
An immutable representation of a Camel message.
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.0) Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
-
trait
Consumer extends Actor with CamelSupport
Mixed in by Actor implementations that consume message from Camel endpoints.
Mixed in by Actor implementations that consume message from Camel endpoints.
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.0) Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
-
trait
Oneway extends Producer
A one-way producer.
A one-way producer.
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.0) Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
-
trait
Producer extends ProducerSupport
Mixed in by Actor implementations to produce messages to Camel endpoints.
Mixed in by Actor implementations to produce messages to Camel endpoints.
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.0) Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
Value Members
-
implicit
def
toActorRouteDefinition[T <: ProcessorDefinition[T]](definition: ProcessorDefinition[T]): ActorRouteDefinition[T]
To allow using Actors with the Camel Route DSL:
To allow using Actors with the Camel Route DSL:
from("file://data/input/CamelConsumer").to(actor)
-
object
Ack extends Product with Serializable
Positive acknowledgement message (used for application-acknowledged message receipts).
Positive acknowledgement message (used for application-acknowledged message receipts). When
autoAck
is set to false in the akka.camel.Consumer, you can send anAck
to the sender of the CamelMessage. -
object
CamelExtension extends ExtensionId[Camel] with ExtensionIdProvider
This class can be used to get hold of an instance of the Camel class bound to the actor system.
This class can be used to get hold of an instance of the Camel class bound to the actor system.
For example:
val system = ActorSystem("some system") val camel = CamelExtension(system) camel.context.addRoutes(...)
- See also
akka.actor.ExtensionId
akka.actor.ExtensionIdProvider
-
object
CamelMessage extends (Any, Map[String, Any]) ⇒ CamelMessage with Serializable
Companion object of CamelMessage class.