- Ack - Class in akka.camel
-
Positive acknowledgement message (used for application-acknowledged message receipts).
- Ack() - Constructor for class akka.camel.Ack
-
- Ack$ - Class in akka.camel
-
Positive acknowledgement message (used for application-acknowledged message receipts).
- Ack$() - Constructor for class akka.camel.Ack$
-
- activated(List<ActorRef>) - Method in class akka.camel.internal.ActivationTracker.ActivationStateMachine
-
Activated state.
- Activation - Interface in akka.camel
-
Activation trait that can be used to wait on activation or de-activation of Camel endpoints.
- activationFutureFor(ActorRef, Timeout, ExecutionContext) - Method in interface akka.camel.Activation
-
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.
- activationFutureFor(ActorRef, Timeout, ExecutionContext) - Method in class akka.camel.internal.DefaultCamel
-
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.
- ActivationMessage(ActorRef) - Constructor for class akka.camel.internal.ActivationProtocol.ActivationMessage
-
- ActivationMessage$() - Constructor for class akka.camel.internal.ActivationProtocol.ActivationMessage$
-
- ActivationProtocol - Class in akka.camel.internal
-
- ActivationProtocol() - Constructor for class akka.camel.internal.ActivationProtocol
-
- ActivationProtocol$ - Class in akka.camel.internal
-
- ActivationProtocol$() - Constructor for class akka.camel.internal.ActivationProtocol$
-
- ActivationProtocol.ActivationMessage - Class in akka.camel.internal
-
Super class of all activation messages.
- ActivationProtocol.ActivationMessage$ - Class in akka.camel.internal
-
INTERNAL API
companion object of ActivationMessage
- ActivationProtocol.EndpointActivated - Class in akka.camel.internal
-
INTERNAL API
Event message indicating that a single endpoint has been activated.
- ActivationProtocol.EndpointActivated$ - Class in akka.camel.internal
-
- ActivationProtocol.EndpointDeActivated - Class in akka.camel.internal
-
INTERNAL API
Event message indicating that a single endpoint was de-activated.
- ActivationProtocol.EndpointDeActivated$ - Class in akka.camel.internal
-
- ActivationProtocol.EndpointFailedToActivate - Class in akka.camel.internal
-
INTERNAL API
Event message indicating that a single endpoint failed to activate.
- ActivationProtocol.EndpointFailedToActivate$ - Class in akka.camel.internal
-
- ActivationProtocol.EndpointFailedToDeActivate - Class in akka.camel.internal
-
INTERNAL API
Event message indicating that a single endpoint failed to de-activate.
- ActivationProtocol.EndpointFailedToDeActivate$ - Class in akka.camel.internal
-
- activations() - Method in class akka.camel.internal.ActivationTracker
-
- ActivationStateMachine() - Constructor for class akka.camel.internal.ActivationTracker.ActivationStateMachine
-
- ActivationTimeout() - Method in class akka.camel.CamelSettings
-
Configured setting for how long the actor should wait for activation before it fails.
- activationTimeout() - Method in interface akka.camel.Consumer
-
How long the actor should wait for activation before it fails.
- activationTimeout() - Method in class akka.camel.ConsumerConfig
-
- ActivationTracker - Class in akka.camel.internal
-
INTERNAL API
An actor that tracks activation and de-activation of endpoints.
- ActivationTracker() - Constructor for class akka.camel.internal.ActivationTracker
-
- ActivationTracker.ActivationStateMachine - Class in akka.camel.internal
-
A state machine that keeps track of the endpoint activation status of an actor.
- actor() - Method in class akka.camel.internal.ActivationProtocol.ActivationMessage
-
- ActorActivationException - Exception in akka.camel.internal
-
INTERNAL API
Thrown by the registrars to indicate that the actor could not be activated.
- ActorActivationException(ActorRef, Throwable) - Constructor for exception akka.camel.internal.ActorActivationException
-
- ActorComponent - Class in akka.camel.internal.component
-
- ActorComponent(Camel, ActorSystem) - Constructor for class akka.camel.internal.component.ActorComponent
-
- ActorDeActivationException - Exception in akka.camel.internal
-
INTERNAL API
Thrown by registrars to indicate that the actor could not be de-activated.
- ActorDeActivationException(ActorRef, Throwable) - Constructor for exception akka.camel.internal.ActorDeActivationException
-
- ActorEndpoint - Class in akka.camel.internal.component
-
INTERNAL API
Does what an endpoint does, creates consumers and producers for the component.
- ActorEndpoint(String, ActorComponent, ActorEndpointPath, Camel) - Constructor for class akka.camel.internal.component.ActorEndpoint
-
- ActorEndpointConfig - Interface in akka.camel.internal.component
-
INTERNAL API
Configures the ActorEndpoint
.
- ActorEndpointPath - Class in akka.camel.internal.component
-
INTERNAL API
An endpoint to an ActorRef
param: actorPath the String representation of the path to the actor
- ActorEndpointPath$ - Class in akka.camel.internal.component
-
INTERNAL API
Companion of ActorEndpointPath
- ActorEndpointPath$() - Constructor for class akka.camel.internal.component.ActorEndpointPath$
-
- ActorNotRegisteredException - Exception in akka.camel
-
Thrown to indicate that the actor referenced by an endpoint URI cannot be
found in the actor system.
- ActorNotRegisteredException(String) - Constructor for exception akka.camel.ActorNotRegisteredException
-
- actorPath() - Method in class akka.camel.internal.component.ActorEndpointPath
-
- ActorProducer - Class in akka.camel.internal.component
-
Sends the in-message of an exchange to an untyped actor, identified by an
ActorEndpoint
- ActorProducer(ActorEndpoint, Camel) - Constructor for class akka.camel.internal.component.ActorProducer
-
- actorRef() - Method in class akka.camel.internal.ActivationProtocol.EndpointActivated
-
- actorRef() - Method in class akka.camel.internal.ActivationProtocol.EndpointDeActivated
-
- actorRef() - Method in class akka.camel.internal.ActivationProtocol.EndpointFailedToActivate
-
- actorRef() - Method in class akka.camel.internal.ActivationProtocol.EndpointFailedToDeActivate
-
- actorRef() - Method in exception akka.camel.internal.ActorActivationException
-
- actorRef() - Method in exception akka.camel.internal.ActorDeActivationException
-
- actorRef() - Method in class akka.camel.internal.CamelSupervisor.AddWatch
-
- actorRef() - Method in class akka.camel.internal.CamelSupervisor.DeRegister
-
- actorRef() - Method in class akka.camel.internal.CamelSupervisor.Register
-
- ActorRouteDefinition<T extends org.apache.camel.model.ProcessorDefinition<T>> - Class in akka.camel
-
Wraps a ProcessorDefinition
.
- ActorRouteDefinition(ProcessorDefinition<T>) - Constructor for class akka.camel.ActorRouteDefinition
-
- AddWatch(ActorRef) - Constructor for class akka.camel.internal.CamelSupervisor.AddWatch
-
- AddWatch$() - Constructor for class akka.camel.internal.CamelSupervisor.AddWatch$
-
- akka.camel - package akka.camel
-
- akka.camel.internal - package akka.camel.internal
-
- akka.camel.internal.component - package akka.camel.internal.component
-
- akka.camel.javaapi - package akka.camel.javaapi
-
- AkkaCamelException - Exception in akka.camel
-
An exception indicating that the exchange to the camel endpoint failed.
- AkkaCamelException(Throwable, Map<String, Object>) - Constructor for exception akka.camel.AkkaCamelException
-
- AkkaCamelException(Throwable) - Constructor for exception akka.camel.AkkaCamelException
-
- apply(FiniteDuration, FiniteDuration, boolean, Function1<RouteDefinition, ProcessorDefinition<?>>) - Method in class akka.camel.ConsumerConfig$
-
- apply(FiniteDuration, FiniteDuration, boolean, Function1<RouteDefinition, ProcessorDefinition<?>>) - Static method in class akka.camel.ConsumerConfig
-
- apply(ActorRef) - Method in class akka.camel.internal.component.ActorEndpointPath$
-
- apply(ActorRef) - Static method in class akka.camel.internal.component.ActorEndpointPath
-
- applyUserRouteCustomization(RouteDefinition) - Method in class akka.camel.internal.ConsumerActorRouteBuilder
-
- AutoAck() - Method in class akka.camel.CamelSettings
-
Configured setting which determines whether one-way communications between an endpoint and this consumer actor
should be auto-acknowledged or application-acknowledged.
- autoAck() - Method in interface akka.camel.Consumer
-
Determines whether one-way communications between an endpoint and this consumer actor
should be auto-acknowledged or application-acknowledged.
- autoAck() - Method in class akka.camel.ConsumerConfig
-
- autoAck() - Method in interface akka.camel.internal.component.ActorEndpointConfig
-
- AwaitActivation - Class in akka.camel.internal
-
INTERNAL API
A request message to the ActivationTracker for the status of activation.
- AwaitActivation(ActorRef) - Constructor for class akka.camel.internal.AwaitActivation
-
- AwaitActivation$ - Class in akka.camel.internal
-
- AwaitActivation$() - Constructor for class akka.camel.internal.AwaitActivation$
-
- AwaitDeActivation - Class in akka.camel.internal
-
INTERNAL API
A request message to the ActivationTracker for the status of de-activation.
- AwaitDeActivation(ActorRef) - Constructor for class akka.camel.internal.AwaitDeActivation
-
- AwaitDeActivation$ - Class in akka.camel.internal
-
- AwaitDeActivation$() - Constructor for class akka.camel.internal.AwaitDeActivation$
-
- Camel - Interface in akka.camel
-
Camel trait encapsulates the underlying camel machinery.
- camel() - Method in interface akka.camel.CamelSupport
-
INTERNAL API
Returns a
Camel
trait which provides access to the CamelExtension.
- camel() - Method in class akka.camel.internal.component.ActorEndpoint
-
- camel() - Method in interface akka.camel.internal.component.ActorEndpointConfig
-
- camelContext() - Method in interface akka.camel.CamelSupport
-
Returns the CamelContext.
- CamelExchangeAdapter - Class in akka.camel.internal
-
- CamelExchangeAdapter(Exchange) - Constructor for class akka.camel.internal.CamelExchangeAdapter
-
- CamelExtension - Class in akka.camel
-
This class can be used to get hold of an instance of the Camel class bound to the actor system.
- CamelExtension() - Constructor for class akka.camel.CamelExtension
-
- CamelExtension$ - Class in akka.camel
-
This class can be used to get hold of an instance of the Camel class bound to the actor system.
- CamelExtension$() - Constructor for class akka.camel.CamelExtension$
-
- CamelMessage - Class in akka.camel
-
An immutable representation of a Camel message.
- CamelMessage(Object, Map<String, Object>) - Constructor for class akka.camel.CamelMessage
-
- CamelMessage(Object, Map<String, Object>) - Constructor for class akka.camel.CamelMessage
-
- CamelMessage$ - Class in akka.camel
-
Companion object of CamelMessage class.
- CamelMessage$() - Constructor for class akka.camel.CamelMessage$
-
- CamelPath - Class in akka.camel.internal.component
-
Converts ActorRefs and actorPaths to URI's that point to the actor through the Camel Actor Component.
- CamelPath() - Constructor for class akka.camel.internal.component.CamelPath
-
- CamelPath$ - Class in akka.camel.internal.component
-
Converts ActorRefs and actorPaths to URI's that point to the actor through the Camel Actor Component.
- CamelPath$() - Constructor for class akka.camel.internal.component.CamelPath$
-
- CamelProducerObjects(Endpoint, SendProcessor) - Constructor for class akka.camel.internal.CamelSupervisor.CamelProducerObjects
-
- CamelProducerObjects$() - Constructor for class akka.camel.internal.CamelSupervisor.CamelProducerObjects$
-
- CamelSettings - Class in akka.camel
-
Settings for the Camel Extension
param: config the config
- CamelSettings(Config, DynamicAccess) - Constructor for class akka.camel.CamelSettings
-
- CamelSupervisor - Class in akka.camel.internal
-
INTERNAL API
Top level supervisor for internal Camel actors
- CamelSupervisor() - Constructor for class akka.camel.internal.CamelSupervisor
-
- CamelSupervisor$ - Class in akka.camel.internal
-
INTERNAL API
Messages for the camel supervisor, registrations and de-registrations.
- CamelSupervisor$() - Constructor for class akka.camel.internal.CamelSupervisor$
-
- CamelSupervisor.AddWatch - Class in akka.camel.internal
-
INTERNAL API
Adds a watch for the actor
- CamelSupervisor.AddWatch$ - Class in akka.camel.internal
-
- CamelSupervisor.CamelProducerObjects - Class in akka.camel.internal
-
INTERNAL API
Provides a Producer with the required camel objects to function.
- CamelSupervisor.CamelProducerObjects$ - Class in akka.camel.internal
-
- CamelSupervisor.CamelSupervisorMessage - Interface in akka.camel.internal
-
- CamelSupervisor.DeRegister - Class in akka.camel.internal
-
INTERNAL API
De-registers a producer or a consumer.
- CamelSupervisor.DeRegister$ - Class in akka.camel.internal
-
- CamelSupervisor.Register - Class in akka.camel.internal
-
INTERNAL API
Registers a consumer or a producer.
- CamelSupervisor.Register$ - Class in akka.camel.internal
-
- CamelSupport - Interface in akka.camel
-
- canonicalize(Object) - Method in class akka.camel.CamelMessage$
-
Creates a canonical form of the given message msg
.
- canonicalize(Object) - Static method in class akka.camel.CamelMessage
-
Creates a canonical form of the given message msg
.
- cause() - Method in class akka.camel.FailureResult
-
- cause() - Method in class akka.camel.internal.ActivationProtocol.EndpointFailedToActivate
-
- cause() - Method in class akka.camel.internal.ActivationProtocol.EndpointFailedToDeActivate
-
- config() - Method in class akka.camel.internal.CamelSupervisor.Register
-
- configure() - Method in class akka.camel.internal.ConsumerActorRouteBuilder
-
- Consumer - Interface in akka.camel
-
Mixed in by Actor implementations that consume message from Camel endpoints.
- Consumer$ - Class in akka.camel
-
Internal use only.
- Consumer$() - Constructor for class akka.camel.Consumer$
-
- ConsumerActorRouteBuilder - Class in akka.camel.internal
-
INTERNAL API
Builder of a route to a target which can be an actor.
- ConsumerActorRouteBuilder(String, ActorRef, ConsumerConfig, CamelSettings) - Constructor for class akka.camel.internal.ConsumerActorRouteBuilder
-
- ConsumerConfig - Class in akka.camel
-
INTERNAL API
Captures the configuration of the Consumer.
- ConsumerConfig(FiniteDuration, FiniteDuration, boolean, Function1<RouteDefinition, ProcessorDefinition<?>>) - Constructor for class akka.camel.ConsumerConfig
-
- ConsumerConfig$ - Class in akka.camel
-
- ConsumerConfig$() - Constructor for class akka.camel.ConsumerConfig$
-
- ConsumerRegistrar - Class in akka.camel.internal
-
INTERNAL API
Registers Consumers.
- ConsumerRegistrar(ActorRef) - Constructor for class akka.camel.internal.ConsumerRegistrar
-
- context() - Method in interface akka.camel.Camel
-
Underlying camel context.
- context() - Method in class akka.camel.internal.DefaultCamel
-
- ContextProvider() - Method in class akka.camel.CamelSettings
-
Configured setting, determine the class used to load/retrieve the instance of the Camel Context
- ContextProvider - Interface in akka.camel
-
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.
- Conversions() - Method in class akka.camel.CamelSettings
-
- convertTo(Class<T>, Exchange, Object) - Method in class akka.camel.internal.component.DurationTypeConverter$
-
- convertTo(Class<T>, Exchange, Object) - Static method in class akka.camel.internal.component.DurationTypeConverter
-
- copyContent(CamelMessage, Message) - Method in class akka.camel.CamelMessage$
-
INTERNAL API
copies the content of this CamelMessage to an Apache Camel Message.
- copyContent(CamelMessage, Message) - Static method in class akka.camel.CamelMessage
-
INTERNAL API
copies the content of this CamelMessage to an Apache Camel Message.
- createConsumer(Processor) - Method in class akka.camel.internal.component.ActorEndpoint
-
The ActorEndpoint only supports receiving messages from Camel.
- createEndpoint(String, String, Map<String, Object>) - Method in class akka.camel.internal.component.ActorComponent
-
- createExtension(ExtendedActorSystem) - Method in class akka.camel.CamelExtension$
-
Creates a new instance of Camel and makes sure it gets stopped when the actor system is shutdown.
- createExtension(ExtendedActorSystem) - Static method in class akka.camel.CamelExtension
-
Creates a new instance of Camel and makes sure it gets stopped when the actor system is shutdown.
- createProducer() - Method in class akka.camel.internal.component.ActorEndpoint
-
Creates a new producer which is used send messages into the endpoint.
- get(ActorSystem) - Method in class akka.camel.CamelExtension$
-
- get(ActorSystem) - Static method in class akka.camel.CamelExtension
-
- getActivation() - Method in class akka.camel.javaapi.UntypedConsumerActor
-
Java API: Returns the
Activation
interface
that can be used to wait on activation or de-activation of Camel endpoints.
- getActivation() - Method in class akka.camel.javaapi.UntypedProducerActor
-
''Java API'': Returns the
Activation
interface
that can be used to wait on activation or de-activation of Camel endpoints.
- getAutoAck() - Method in interface akka.camel.internal.component.ActorEndpointConfig
-
- getBodyAs(Class<T>, CamelContext) - Method in class akka.camel.CamelMessage
-
Java API: Returns the body of the message converted to the type as given by the clazz
parameter.
- getCamelContext() - Method in class akka.camel.javaapi.UntypedConsumerActor
-
Java API: Returns the DefaultCamelContext
- getCamelContext() - Method in class akka.camel.javaapi.UntypedProducerActor
-
Returns the CamelContext
.
- getContext(ExtendedActorSystem) - Method in interface akka.camel.ContextProvider
-
Retrieve or create a Camel Context for the given actor system
Called once per actor system
- getContext(ExtendedActorSystem) - Method in class akka.camel.DefaultContextProvider
-
- getEndpointUri() - Method in class akka.camel.javaapi.UntypedConsumerActor
-
Java API: Returns the Camel endpoint URI to consume messages from.
- getEndpointUri() - Method in class akka.camel.javaapi.UntypedProducerActor
-
Returns the Camel endpoint URI to produce messages to.
- getExchangeId() - Method in class akka.camel.internal.CamelExchangeAdapter
-
Returns the exchange id
- getHeaderAs(String, Class<T>, CamelContext) - Method in class akka.camel.CamelMessage
-
Java API: Returns the header by given name
parameter.
- getHeaders(Set<String>) - Method in class akka.camel.CamelMessage
-
Java API: Returns those headers from this message whose name is contained in names
.
- getHeaders() - Method in class akka.camel.CamelMessage
-
Java API: Returns all headers from this message.
- getInstance() - Method in class akka.camel.Ack$
-
Java API to get the Ack singleton
- getInstance() - Static method in class akka.camel.Ack
-
Java API to get the Ack singleton
- getMessage() - Method in exception akka.camel.ActorNotRegisteredException
-
- getProducerTemplate() - Method in class akka.camel.javaapi.UntypedConsumerActor
-
Java API: Returns the ProducerTemplate
- getProducerTemplate() - Method in class akka.camel.javaapi.UntypedProducerActor
-
Returns the ProducerTemplate
.
- getReplyTimeout() - Method in interface akka.camel.internal.component.ActorEndpointConfig
-
- getRouteDefinitionHandler() - Method in interface akka.camel.Consumer
-
Java API: Returns the Mapper
function that will be used as a route definition handler
for creating custom route to this consumer.
- mapBody(Function1<A, B>) - Method in class akka.camel.CamelMessage
-
Returns a new CamelMessage with a transformed body using a transformer
function.
- mapBody(Mapper<A, B>) - Method in class akka.camel.CamelMessage
-
Java API: Returns a new CamelMessage with a transformed body using a transformer
function.
- message() - Method in class akka.camel.MessageResult
-
- MessageExchangeId() - Method in class akka.camel.CamelMessage$
-
CamelMessage header to correlate request with response messages.
- MessageExchangeId() - Static method in class akka.camel.CamelMessage
-
CamelMessage header to correlate request with response messages.
- MessageResult - Class in akka.camel
-
INTERNAL API
- MessageResult(CamelMessage) - Constructor for class akka.camel.MessageResult
-
- MessageResult$ - Class in akka.camel
-
- MessageResult$() - Constructor for class akka.camel.MessageResult$
-
- MODULE$ - Static variable in class akka.camel.Ack$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.CamelExtension$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.CamelMessage$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.Consumer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.ConsumerConfig$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.FailureResult$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.ActivationProtocol$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.ActivationProtocol.ActivationMessage$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.ActivationProtocol.EndpointActivated$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.ActivationProtocol.EndpointDeActivated$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.ActivationProtocol.EndpointFailedToActivate$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.ActivationProtocol.EndpointFailedToDeActivate$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.AwaitActivation$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.AwaitDeActivation$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.CamelSupervisor$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.CamelSupervisor.AddWatch$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.CamelSupervisor.CamelProducerObjects$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.CamelSupervisor.DeRegister$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.CamelSupervisor.Register$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.component.ActorEndpointPath$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.component.CamelPath$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.internal.component.DurationTypeConverter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.camel.MessageResult$
-
Static reference to the singleton instance of this Scala object.
- targetActorUri() - Method in class akka.camel.internal.ConsumerActorRouteBuilder
-
- template() - Method in interface akka.camel.Camel
-
The Camel ProducerTemplate.
- template() - Method in class akka.camel.internal.DefaultCamel
-
- to(ActorRef) - Method in class akka.camel.ActorRouteDefinition
-
Sends the message to an ActorRef endpoint.
- to(ActorRef, boolean, Duration) - Method in class akka.camel.ActorRouteDefinition
-
Sends the message to an ActorRef endpoint
- toAkkaCamelException() - Method in class akka.camel.internal.CamelExchangeAdapter
-
Creates an AkkaCamelException object from the adapted Exchange.
- toAkkaCamelException(Map<String, Object>) - Method in class akka.camel.internal.CamelExchangeAdapter
-
Creates an AkkaCamelException object from the adapted Exchange.
- toFailureMessage() - Method in class akka.camel.internal.CamelExchangeAdapter
-
Creates an immutable Failure object from the adapted Exchange so it can be used internally between Actors.
- toFailureResult(Map<String, Object>) - Method in class akka.camel.internal.CamelExchangeAdapter
-
Creates an immutable FailureResult object from the adapted Exchange so it can be used internally between Actors.
- toRequestMessage() - Method in class akka.camel.internal.CamelExchangeAdapter
-
Creates an immutable CamelMessage object from Exchange.getIn so it can be used with Actors.
- toRequestMessage(Map<String, Object>) - Method in class akka.camel.internal.CamelExchangeAdapter
-
Creates an immutable CamelMessage object from Exchange.getIn so it can be used with Actors.
- toResponseMessage() - Method in class akka.camel.internal.CamelExchangeAdapter
-
Depending on the exchange pattern, creates an immutable CamelMessage object from Exchange.getIn or Exchange.getOut so it can be used with Actors.
- toResponseMessage(Map<String, Object>) - Method in class akka.camel.internal.CamelExchangeAdapter
-
Depending on the exchange pattern, creates an immutable CamelMessage object from Exchange.getIn or Exchange.getOut so it can be used with Actors.
- toString() - Method in class akka.camel.CamelMessage
-
- toUri(ActorRef) - Method in class akka.camel.internal.component.CamelPath$
-
Converts the actorRef to a Camel URI (string) which can be used in custom routes.
- toUri(ActorRef, boolean, Duration) - Method in class akka.camel.internal.component.CamelPath$
-
Converts the actorRef to a Camel URI (string) which can be used in custom routes.
- toUri(ActorRef) - Static method in class akka.camel.internal.component.CamelPath
-
Converts the actorRef to a Camel URI (string) which can be used in custom routes.
- toUri(ActorRef, boolean, Duration) - Static method in class akka.camel.internal.component.CamelPath
-
Converts the actorRef to a Camel URI (string) which can be used in custom routes.
- transformOutgoingMessage(Object) - Method in class akka.camel.javaapi.UntypedProducerActor
-
- transformOutgoingMessage(Object) - Method in interface akka.camel.ProducerSupport
-
Called before the message is sent to the endpoint specified by endpointUri
.
- transformResponse(Object) - Method in class akka.camel.javaapi.UntypedProducerActor
-
- transformResponse(Object) - Method in interface akka.camel.ProducerSupport
-
Called before the response message is sent to the original sender.