Skip navigation links
A B C D E F G H I J L M N O P R S T U W 

A

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
INTERNAL API Creates Camel Endpoints that send messages to Consumer actors through an ActorProducer.
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$
 

B

body() - Method in class akka.camel.CamelMessage
 
bodyAs(ClassTag<T>, CamelContext) - Method in class akka.camel.CamelMessage
Returns the body of the message converted to the type T.

C

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
INTERNAL API Adapter for converting an Exchange to and from CamelMessage and FailureResult objects.
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.

D

deactivated() - Method in class akka.camel.internal.ActivationTracker.ActivationStateMachine
De-activated state
deactivationFutureFor(ActorRef, Timeout, ExecutionContext) - Method in interface akka.camel.Activation
Produces a Future which will be completed when the given endpoint has been deactivated or or if it times out, which will happen after the specified Timeout.
deactivationFutureFor(ActorRef, Timeout, ExecutionContext) - Method in class akka.camel.internal.DefaultCamel
Produces a Future which will be completed when the given endpoint has been deactivated or or if it times out, which will happen after the specified Timeout.
DefaultCamel - Class in akka.camel.internal
INTERNAL API Creates an instance of the Camel subsystem.
DefaultCamel(ExtendedActorSystem) - Constructor for class akka.camel.internal.DefaultCamel
 
DefaultContextProvider - Class in akka.camel
Default implementation of ContextProvider Provides a new DefaultCamelContext per actor system
DefaultContextProvider() - Constructor for class akka.camel.DefaultContextProvider
 
DeRegister(ActorRef) - Constructor for class akka.camel.internal.CamelSupervisor.DeRegister
 
DeRegister$() - Constructor for class akka.camel.internal.CamelSupervisor.DeRegister$
 
DurationTypeConverter - Class in akka.camel.internal.component
INTERNAL API Converts Strings to Duration
DurationTypeConverter() - Constructor for class akka.camel.internal.component.DurationTypeConverter
 
DurationTypeConverter$ - Class in akka.camel.internal.component
INTERNAL API Converts Strings to Duration
DurationTypeConverter$() - Constructor for class akka.camel.internal.component.DurationTypeConverter$
 

E

endpoint() - Method in class akka.camel.internal.CamelSupervisor.CamelProducerObjects
 
endpoint() - Method in class akka.camel.internal.component.ActorProducer
 
EndpointActivated(ActorRef) - Constructor for class akka.camel.internal.ActivationProtocol.EndpointActivated
 
EndpointActivated$() - Constructor for class akka.camel.internal.ActivationProtocol.EndpointActivated$
 
EndpointDeActivated(ActorRef) - Constructor for class akka.camel.internal.ActivationProtocol.EndpointDeActivated
 
EndpointDeActivated$() - Constructor for class akka.camel.internal.ActivationProtocol.EndpointDeActivated$
 
EndpointFailedToActivate(ActorRef, Throwable) - Constructor for class akka.camel.internal.ActivationProtocol.EndpointFailedToActivate
 
EndpointFailedToActivate$() - Constructor for class akka.camel.internal.ActivationProtocol.EndpointFailedToActivate$
 
EndpointFailedToDeActivate(ActorRef, Throwable) - Constructor for class akka.camel.internal.ActivationProtocol.EndpointFailedToDeActivate
 
EndpointFailedToDeActivate$() - Constructor for class akka.camel.internal.ActivationProtocol.EndpointFailedToDeActivate$
 
endpointUri() - Method in interface akka.camel.Consumer
Must return the Camel endpoint URI that the consumer wants to consume messages from.
endpointUri() - Method in class akka.camel.internal.CamelSupervisor.Register
 
endpointUri() - Method in class akka.camel.javaapi.UntypedConsumerActor
 
endpointUri() - Method in class akka.camel.javaapi.UntypedProducerActor
 
endpointUri() - Method in interface akka.camel.ProducerSupport
Returns the Camel endpoint URI to produce messages to.
exchange() - Method in class akka.camel.internal.CamelExchangeAdapter
 

F

failedToActivate(Throwable) - Method in class akka.camel.internal.ActivationTracker.ActivationStateMachine
Failed to activate state
failedToDeActivate(Throwable) - Method in class akka.camel.internal.ActivationTracker.ActivationStateMachine
Failed to de-activate state
FailureResult - Class in akka.camel
INTERNAL API
FailureResult(Throwable, Map<String, Object>) - Constructor for class akka.camel.FailureResult
 
FailureResult$ - Class in akka.camel
 
FailureResult$() - Constructor for class akka.camel.FailureResult$
 
findActorIn(ActorSystem) - Method in class akka.camel.internal.component.ActorEndpointPath
 
from(Message, Map<String, Object>) - Method in class akka.camel.CamelMessage$
Creates a new CamelMessage object from the Camel message.
from(Message, Map<String, Object>) - Static method in class akka.camel.CamelMessage
Creates a new CamelMessage object from the Camel message.
fromCamelPath(String) - Method in class akka.camel.internal.component.ActorEndpointPath$
Creates an ActorEndpointPath from the uri Expects the uri in the akka ActorPath format, i.e 'akka://system/user/someactor'.
fromCamelPath(String) - Static method in class akka.camel.internal.component.ActorEndpointPath
Creates an ActorEndpointPath from the uri Expects the uri in the akka ActorPath format, i.e 'akka://system/user/someactor'.

G

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.

H

headerAs(String, ClassTag<T>, CamelContext) - Method in class akka.camel.CamelMessage
Returns the header by given name parameter in a Try.
headers() - Method in exception akka.camel.AkkaCamelException
 
headers() - Method in class akka.camel.CamelMessage
 
headers(Set<String>) - Method in class akka.camel.CamelMessage
Returns those headers from this message whose name is contained in names.
headers() - Method in class akka.camel.FailureResult
 
headersToCopy() - Method in interface akka.camel.ProducerSupport
Returns the names of message headers to copy from a request message to a response message.
headersToCopyDefault() - Method in interface akka.camel.ProducerSupport
CamelMessage headers to copy by default from request message to response-message.

I

identityRouteMapper() - Method in class akka.camel.Consumer$
 
isOneway() - Method in class akka.camel.javaapi.UntypedProducerActor
If set to false (default), this producer expects a response message from the Camel endpoint.
isOutCapable() - Method in class akka.camel.internal.CamelExchangeAdapter
Returns if the exchange is out capable.
isSingleton() - Method in class akka.camel.internal.component.ActorEndpoint
Returns true.

J

JmxStatistics() - Method in class akka.camel.CamelSettings
 

L

log() - Method in class akka.camel.internal.DefaultCamel
 
logFailure(ActorContext, ActorRef, Throwable, SupervisorStrategy.Directive) - Method in class akka.camel.internal.Registry.RegistryLogStrategy
 
lookup() - Method in class akka.camel.CamelExtension$
 
lookup() - Static method in class akka.camel.CamelExtension
 

M

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.

N

notActivated() - Method in class akka.camel.internal.ActivationTracker.ActivationStateMachine
Not activated state

O

oneway() - Method in class akka.camel.javaapi.UntypedProducerActor
 
Oneway - Interface in akka.camel
A one-way producer.
oneway() - Method in interface akka.camel.Oneway
 
oneway() - Method in interface akka.camel.ProducerSupport
If set to false (default), this producer expects a response message from the Camel endpoint.
onReceive(Object) - Method in class akka.camel.javaapi.UntypedProducerActor
Default implementation of UntypedActor.onReceive
onRouteDefinition() - Method in interface akka.camel.Consumer
Returns the route definition handler for creating a custom route to this consumer.
onRouteDefinition() - Method in class akka.camel.ConsumerConfig
 
onRouteResponse(Object) - Method in class akka.camel.javaapi.UntypedProducerActor
Called after a response was received from the endpoint specified by endpointUri.
onTransformOutgoingMessage(Object) - Method in class akka.camel.javaapi.UntypedProducerActor
Called before the message is sent to the endpoint specified by getEndpointUri.
onTransformResponse(Object) - Method in class akka.camel.javaapi.UntypedProducerActor
Called before the response message is sent to original sender.

P

path() - Method in class akka.camel.internal.component.ActorEndpoint
 
path() - Method in interface akka.camel.internal.component.ActorEndpointConfig
 
preStart() - Method in interface akka.camel.Consumer
Registers the consumer endpoint.
preStart() - Method in interface akka.camel.ProducerSupport
 
process(Exchange) - Method in class akka.camel.internal.component.ActorProducer
Processes the exchange.
process(Exchange, AsyncCallback) - Method in class akka.camel.internal.component.ActorProducer
Processes the message exchange.
processExchangeAdapter(CamelExchangeAdapter) - Method in class akka.camel.internal.component.ActorProducer
INTERNAL API Processes the CamelExchangeAdapter
processExchangeAdapter(CamelExchangeAdapter, AsyncCallback) - Method in class akka.camel.internal.component.ActorProducer
INTERNAL API Processes the CamelExchangeAdapter.
processor() - Method in class akka.camel.internal.CamelSupervisor.CamelProducerObjects
 
produce() - Method in interface akka.camel.ProducerSupport
Produces msg to the endpoint specified by endpointUri.
produce(Endpoint, SendProcessor, Object, ExchangePattern) - Method in class akka.camel.ProducerSupport.ProducerChild
Initiates a message exchange of given pattern with the endpoint specified by endpointUri.
Producer - Interface in akka.camel
Mixed in by Actor implementations to produce messages to Camel endpoints.
ProducerChild(Endpoint, SendProcessor) - Constructor for class akka.camel.ProducerSupport.ProducerChild
 
ProducerRegistrar - Class in akka.camel.internal
INTERNAL API Registers Producers.
ProducerRegistrar(ActorRef) - Constructor for class akka.camel.internal.ProducerRegistrar
 
ProducerSupport - Interface in akka.camel
Support trait for producing messages to Camel endpoints.
ProducerSupport.ProducerChild - Class in akka.camel
 

R

receive() - Method in class akka.camel.internal.ActivationTracker.ActivationStateMachine
 
receive() - Method in class akka.camel.internal.ActivationTracker
 
receive() - Method in class akka.camel.internal.CamelSupervisor
 
receive() - Method in class akka.camel.internal.ConsumerRegistrar
 
receive() - Method in class akka.camel.internal.ProducerRegistrar
 
receive() - Method in class akka.camel.internal.Registry
 
receive() - Method in interface akka.camel.Producer
Implementation of Actor.receive.
receive() - Method in class akka.camel.ProducerSupport.ProducerChild
 
ref() - Method in class akka.camel.internal.AwaitActivation
 
ref() - Method in class akka.camel.internal.AwaitDeActivation
 
register() - Method in interface akka.camel.Consumer
 
Register(ActorRef, String, Option<ConsumerConfig>) - Constructor for class akka.camel.internal.CamelSupervisor.Register
 
register() - Method in interface akka.camel.ProducerSupport
 
Register$() - Constructor for class akka.camel.internal.CamelSupervisor.Register$
 
Registry - Class in akka.camel.internal
INTERNAL API Registry for Camel Consumers and Producers.
Registry(ActorRef) - Constructor for class akka.camel.internal.Registry
 
Registry.RegistryLogStrategy - Class in akka.camel.internal
 
RegistryLogStrategy(PartialFunction<Throwable, SupervisorStrategy.Directive>) - Constructor for class akka.camel.internal.Registry.RegistryLogStrategy
 
ReplyTimeout() - Method in class akka.camel.CamelSettings
Configured setting, 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.
replyTimeout() - Method in interface akka.camel.Consumer
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.
replyTimeout() - Method in class akka.camel.ConsumerConfig
 
replyTimeout() - Method in interface akka.camel.internal.component.ActorEndpointConfig
 
resetStreamCache() - Method in class akka.camel.CamelMessage
Reset StreamCache body.
routeResponse(Object) - Method in class akka.camel.javaapi.UntypedProducerActor
 
routeResponse(Object) - Method in interface akka.camel.ProducerSupport
Called after a response was received from the endpoint specified by endpointUri.

S

setAutoAck(boolean) - Method in interface akka.camel.internal.component.ActorEndpointConfig
 
setFailure(FailureResult) - Method in class akka.camel.internal.CamelExchangeAdapter
Sets Exchange.getException from the given FailureResult message.
setReplyTimeout(FiniteDuration) - Method in interface akka.camel.internal.component.ActorEndpointConfig
 
setRequest(CamelMessage) - Method in class akka.camel.internal.CamelExchangeAdapter
Sets Exchange.getIn from the given CamelMessage object.
setResponse(CamelMessage) - Method in class akka.camel.internal.CamelExchangeAdapter
Depending on the exchange pattern, sets Exchange.getIn or Exchange.getOut from the given CamelMessage object.
settings() - Method in interface akka.camel.Camel
The settings for the CamelExtension
settings() - Method in class akka.camel.internal.DefaultCamel
 
shutdown() - Method in class akka.camel.internal.DefaultCamel
Stops camel and underlying camel context and template.
start() - Method in class akka.camel.internal.DefaultCamel
Starts camel and underlying camel context and template.
StreamingCache() - Method in class akka.camel.CamelSettings
enables or disables streamingCache on the Camel Context
supervisor() - Method in interface akka.camel.Camel
INTERNAL API Returns the camel supervisor actor.
supervisor() - Method in class akka.camel.internal.DefaultCamel
 
supervisorStrategy() - Method in class akka.camel.internal.CamelSupervisor
 
supervisorStrategy() - Method in class akka.camel.internal.Registry
 
system() - Method in interface akka.camel.Camel
INTERNAL API Returns the associated ActorSystem.
system() - Method in class akka.camel.internal.DefaultCamel
 

T

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.

U

unapply(ActivationProtocol.ActivationMessage) - Method in class akka.camel.internal.ActivationProtocol.ActivationMessage$
 
UntypedConsumerActor - Class in akka.camel.javaapi
Subclass this abstract class to create an MDB-style untyped consumer actor.
UntypedConsumerActor() - Constructor for class akka.camel.javaapi.UntypedConsumerActor
 
UntypedProducerActor - Class in akka.camel.javaapi
Subclass this abstract class to create an untyped producer actor.
UntypedProducerActor() - Constructor for class akka.camel.javaapi.UntypedProducerActor
 

W

withBody(T) - Method in class akka.camel.CamelMessage
Java API: Returns a new CamelMessage with a new body, while keeping the same headers.
withBodyAs(ClassTag<T>, CamelContext) - Method in class akka.camel.CamelMessage
Creates a CamelMessage with current body converted to type T.
withBodyAs(Class<T>, CamelContext) - Method in class akka.camel.CamelMessage
Java API: Creates a CamelMessage with current body converted to type clazz.
withHeaders(Map<String, A>) - Method in class akka.camel.CamelMessage
Java API: Creates a new CamelMessage with given headers.
A B C D E F G H I J L M N O P R S T U W 
Skip navigation links