Merge pull request #1935 from drexin/wip-3544-improve-testkit

+tes Added system as default param to TestKit.shutdown
This commit is contained in:
Patrik Nordwall 2014-01-20 05:12:17 -08:00
commit 8ec581c808
7 changed files with 7 additions and 7 deletions

View file

@ -31,7 +31,7 @@ class ProducerFeatureTest extends TestKit(ActorSystem("ProducerFeatureTest", Akk
override protected def afterAll() {
super.afterAll()
shutdown(system)
shutdown()
}
val camelContext = camel.context

View file

@ -11,7 +11,7 @@ import akka.camel.internal.ActivationProtocol._
class ActivationTrackerTest extends TestKit(ActorSystem("test")) with WordSpecLike with Matchers with BeforeAndAfterAll with BeforeAndAfterEach with GivenWhenThen {
override protected def afterAll() { shutdown(system) }
override protected def afterAll() { shutdown() }
var actor: TestProbe = _
var awaiting: Awaiting = _

View file

@ -379,7 +379,7 @@ private[camel] trait ActorProducerFixture extends MockitoSugar with BeforeAndAft
}
override protected def afterAll() {
shutdown(system)
shutdown()
}
def msg(s: String) = CamelMessage(s, Map.empty)

View file

@ -46,7 +46,7 @@ class TimerBasedThrottlerSpec extends TestKit(ActorSystem("TimerBasedThrottlerSp
import TimerBasedThrottlerSpec._
override def afterAll {
shutdown(system)
shutdown()
}
"A throttler" must {

View file

@ -45,7 +45,7 @@ class TestKitUsageSpec
system.actorOf(Props(classOf[SequencingActor], testActor, headList, tailList))
override def afterAll {
shutdown(system)
shutdown()
}
"An EchoActor" should {

View file

@ -656,7 +656,7 @@ trait TestKitBase {
*
* If verifySystemShutdown is true, then an exception will be thrown on failure.
*/
def shutdown(actorSystem: ActorSystem,
def shutdown(actorSystem: ActorSystem = system,
duration: Duration = 5.seconds.dilated.min(10.seconds),
verifySystemShutdown: Boolean = false) {
TestKit.shutdownActorSystem(actorSystem, duration, verifySystemShutdown)

View file

@ -74,7 +74,7 @@ abstract class AkkaSpec(_system: ActorSystem)
final override def afterAll {
beforeTermination()
shutdown(system)
shutdown()
afterTermination()
stopCoroner()
}