Package akka.camel
Interface Consumer
-
- All Superinterfaces:
Actor
,CamelSupport
- All Known Implementing Classes:
UntypedConsumerActor
public interface Consumer extends Actor, CamelSupport
Deprecated.Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel). Since 2.5.0.Must return the Camel endpoint URI that the consumer wants to consume messages from.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description scala.concurrent.duration.FiniteDuration
activationTimeout()
Deprecated.How long the actor should wait for activation before it fails.boolean
autoAck()
Deprecated.Determines whether one-way communications between an endpoint and this consumer actor should be auto-acknowledged or application-acknowledged.java.lang.String
endpointUri()
Deprecated.Must return the Camel endpoint URI that the consumer wants to consume messages from.Mapper<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>>
getRouteDefinitionHandler()
Deprecated.Java API: Returns theMapper
function that will be used as a route definition handler for creating custom route to this consumer.scala.Function1<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>>
onRouteDefinition()
Deprecated.Returns the route definition handler for creating a custom route to this consumer.void
preStart()
Deprecated.Registers the consumer endpoint.void
register()
Deprecated.scala.concurrent.duration.FiniteDuration
replyTimeout()
Deprecated.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.void
super$preStart()
Deprecated.-
Methods inherited from interface akka.actor.Actor
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.camel.CamelSupport
akka$camel$CamelSupport$_setter_$camel_$eq, camel, camelContext
-
-
-
-
Method Detail
-
super$preStart
void super$preStart()
Deprecated.
-
endpointUri
java.lang.String endpointUri()
Deprecated.Must return the Camel endpoint URI that the consumer wants to consume messages from.- Returns:
- (undocumented)
-
preStart
void preStart() throws java.lang.Exception
Deprecated.Registers the consumer endpoint. Note: when overriding this method, be sure to call 'super.preRestart', otherwise the consumer endpoint will not be registered.
-
register
void register()
Deprecated.
-
activationTimeout
scala.concurrent.duration.FiniteDuration activationTimeout()
Deprecated.How long the actor should wait for activation before it fails.- Returns:
- (undocumented)
-
replyTimeout
scala.concurrent.duration.FiniteDuration replyTimeout()
Deprecated.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:
- (undocumented)
-
autoAck
boolean autoAck()
Deprecated.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.- Returns:
- (undocumented)
-
onRouteDefinition
scala.Function1<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>> onRouteDefinition()
Deprecated.Returns the route definition handler for creating a custom route to this consumer. By default it returns an identity function, override this method to return a custom route definition handler. The returned function is not allowed to close over 'this', meaning it is not allowed to refer to the actor instance itself, since that can easily cause concurrent shared state issues.- Returns:
- (undocumented)
-
getRouteDefinitionHandler
Mapper<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>> getRouteDefinitionHandler()
Deprecated.Java API: Returns theMapper
function that will be used as a route definition handler for creating custom route to this consumer. By default it returns an identity function, override this method to return a custom route definition handler. TheMapper
is not allowed to close over 'this', meaning it is not allowed to refer to the actor instance itself, since that can easily cause concurrent shared state issues.- Returns:
- (undocumented)
-
-