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.

    • 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.
        Specified by:
        preStart in interface Actor
        Throws:
        java.lang.Exception

      • 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 the Mapper 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. The Mapper 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)