akka.camel

Class ConsumerConfig

java.lang.Object

akka.camel.ConsumerConfig

All Implemented Interfaces:

NoSerializationVerificationNeeded, java.io.Serializable

public class ConsumerConfig
extends java.lang.Object
implements NoSerializationVerificationNeeded, scala.Serializable

INTERNAL API Captures the configuration of the Consumer.

Was a case class but has been split up as a workaround for SI-8283

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConsumerConfig(scala.concurrent.duration.FiniteDuration activationTimeout, scala.concurrent.duration.FiniteDuration replyTimeout, boolean autoAck, scala.Function1<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>> onRouteDefinition)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.duration.FiniteDuration	activationTimeout()
static ConsumerConfig	apply(scala.concurrent.duration.FiniteDuration activationTimeout, scala.concurrent.duration.FiniteDuration replyTimeout, boolean autoAck, scala.Function1<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>> onRouteDefinition)
boolean	autoAck()
scala.Function1<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>>	onRouteDefinition()
scala.concurrent.duration.FiniteDuration	replyTimeout()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConsumerConfig

public ConsumerConfig(scala.concurrent.duration.FiniteDuration activationTimeout,
                      scala.concurrent.duration.FiniteDuration replyTimeout,
                      boolean autoAck,
                      scala.Function1<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>> onRouteDefinition)

Method Detail

apply

public static ConsumerConfig apply(scala.concurrent.duration.FiniteDuration activationTimeout,
                                   scala.concurrent.duration.FiniteDuration replyTimeout,
                                   boolean autoAck,
                                   scala.Function1<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>> onRouteDefinition)

activationTimeout

public scala.concurrent.duration.FiniteDuration activationTimeout()

replyTimeout

public scala.concurrent.duration.FiniteDuration replyTimeout()

autoAck

public boolean autoAck()

onRouteDefinition

public scala.Function1<org.apache.camel.model.RouteDefinition,org.apache.camel.model.ProcessorDefinition<?>> onRouteDefinition()