raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Restructuring the CamelConfigSpec for fun and profit

Browse source
This commit is contained in:
Viktor Klang 2012-09-26 17:30:09 +02:00
parent cd0c96ff9c
commit 4441b03e07
1 changed files with 25 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

42
akka-camel/src/test/scala/akka/camel/CamelConfigSpec.scala
View file

@ -11,30 +11,38 @@ import java.util.concurrent.TimeUnit._
class CamelConfigSpec extends WordSpec with MustMatchers { class CamelConfigSpec extends WordSpec with MustMatchers {
val (settings, config) = {
val system = ActorSystem("CamelConfigSpec")
val result = (CamelExtension(system).settings, system.settings.config)
system.shutdown()
result
}
"CamelConfigSpec" must { "CamelConfigSpec" must {
"have correct config" in { "have correct activationTimeout config" in {
val system = ActorSystem("CamelConfigSpec") settings.activationTimeout must be === Duration(config.getMilliseconds("akka.camel.consumer.activation-timeout"), MILLISECONDS)
try { }
val settings = CamelExtension(system).settings
val config = system.settings.config "have correct autoAck config" in {
settings.autoAck must be === config.getBoolean("akka.camel.consumer.auto-ack")
}
settings.activationTimeout must be === Duration(config.getMilliseconds("akka.camel.consumer.activation-timeout"), MILLISECONDS) "have correct replyTimeout config" in {
settings.replyTimeout must be === Duration(config.getMilliseconds("akka.camel.consumer.reply-timeout"), MILLISECONDS)
}
settings.autoAck must be === config.getBoolean("akka.camel.consumer.auto-ack") "have correct streamingCache config" in {
settings.streamingCache must be === config.getBoolean("akka.camel.streamingCache")
}
settings.replyTimeout must be === Duration(config.getMilliseconds("akka.camel.consumer.reply-timeout"), MILLISECONDS) "have correct jmxStatistics config" in {
settings.jmxStatistics must be === config.getBoolean("akka.camel.jmx")
}
settings.streamingCache must be === config.getBoolean("akka.camel.streamingCache") "have correct body conversions config" in {
val conversions = config.getConfig("akka.camel.conversions")
settings.jmxStatistics must be === config.getBoolean("akka.camel.jmx") conversions.getString("file") must be === "java.io.InputStream"
conversions.entrySet.size must be === 1
val conversions = config.getConfig("akka.camel.conversions")
conversions.getString("file") must be === "java.io.InputStream"
conversions.entrySet.size must be === 1
} finally system.shutdown()
} }
} }
} }