!cam Splitting up case class as workaround for SI-8283

This commit is contained in:
Björn Antonsson 2014-02-14 13:06:35 +01:00
parent 70e30fb15b
commit 98d9782db9
2 changed files with 14 additions and 1 deletions

View file

@ -10,6 +10,8 @@ import akka.actor._
import scala.concurrent.duration._
import akka.dispatch.Mapper
import scala.language.existentials
/**
* Mixed in by Actor implementations that consume message from Camel endpoints.
*
@ -87,8 +89,17 @@ private[camel] object Consumer {
override def checkedApply(rd: RouteDefinition): ProcessorDefinition[_] = rd
}
}
/**
* INTERNAL API
* Captures the configuration of the Consumer.
*
* Was a case class but has been split up as a workaround for SI-8283
*/
private[camel] case class ConsumerConfig(activationTimeout: FiniteDuration, replyTimeout: FiniteDuration, autoAck: Boolean, onRouteDefinition: RouteDefinition ProcessorDefinition[_]) extends NoSerializationVerificationNeeded
private[camel] class ConsumerConfig(val activationTimeout: FiniteDuration, val replyTimeout: FiniteDuration, val autoAck: Boolean, val onRouteDefinition: RouteDefinition ProcessorDefinition[_]) extends NoSerializationVerificationNeeded
with scala.Serializable
private[camel] object ConsumerConfig {
def apply(activationTimeout: FiniteDuration, replyTimeout: FiniteDuration, autoAck: Boolean, onRouteDefinition: RouteDefinition ProcessorDefinition[_]): ConsumerConfig =
new ConsumerConfig(activationTimeout, replyTimeout, autoAck, onRouteDefinition)
}

View file

@ -10,6 +10,8 @@ import akka.camel.internal.component.CamelPath
import org.apache.camel.builder.RouteBuilder
import org.apache.camel.model.RouteDefinition
import scala.language.existentials
/**
* INTERNAL API
* Builder of a route to a target which can be an actor.