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 |
ConsumerConfig(scala.concurrent.duration.FiniteDuration activationTimeout,
scala.concurrent.duration.FiniteDuration replyTimeout,
boolean autoAck,
scala.Function1<org.apache.camel.model.RouteDefinition,> onRouteDefinition)
|
Method Summary |
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,> onRouteDefinition)
|
boolean |
autoAck()
|
scala.Function1<org.apache.camel.model.RouteDefinition,> |
onRouteDefinition()
|
scala.concurrent.duration.FiniteDuration |
replyTimeout()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConsumerConfig
public ConsumerConfig(scala.concurrent.duration.FiniteDuration activationTimeout,
scala.concurrent.duration.FiniteDuration replyTimeout,
boolean autoAck,
scala.Function1<org.apache.camel.model.RouteDefinition,> onRouteDefinition)
apply
public static ConsumerConfig apply(scala.concurrent.duration.FiniteDuration activationTimeout,
scala.concurrent.duration.FiniteDuration replyTimeout,
boolean autoAck,
scala.Function1<org.apache.camel.model.RouteDefinition,> 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,> onRouteDefinition()