Package akka.camel
Class ConsumerConfig
- java.lang.Object
-
- akka.camel.ConsumerConfig
-
- All Implemented Interfaces:
NoSerializationVerificationNeeded
,java.io.Serializable
,scala.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 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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
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()
-
-