|
Akka/Scala example source code file (ActorComponentConfigurationTest.scala)
The ActorComponentConfigurationTest.scala Akka example source code
/**
* Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.camel.internal.component
import language.postfixOps
import org.scalatest.Matchers
import scala.concurrent.duration._
import akka.camel.TestSupport.SharedCamelSystem
import org.apache.camel.Component
import org.scalatest.WordSpec
class ActorComponentConfigurationTest extends WordSpec with Matchers with SharedCamelSystem {
val component: Component = camel.context.getComponent("akka")
"Endpoint url config should be correctly parsed" in {
val actorEndpointConfig = component.createEndpoint("akka://test/user/$a?autoAck=false&replyTimeout=987000000+nanos").asInstanceOf[ActorEndpointConfig]
actorEndpointConfig should have(
'endpointUri("akka://test/user/$a?autoAck=false&replyTimeout=987000000+nanos"),
'path(ActorEndpointPath.fromCamelPath("akka://test/user/$a")),
'autoAck(false),
'replyTimeout(987000000 nanos))
}
}
Other Akka source code examplesHere is a short list of links related to this Akka ActorComponentConfigurationTest.scala source code file: |
| ... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2024 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.