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

Prolonging the timeouts for the ProducerRegistryTest

Browse source
This commit is contained in:
Viktor Klang 2012-07-03 21:26:05 +02:00
parent 63d6ac2a7e
commit d4f759646c
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-camel/src/test/scala/akka/camel/ProducerRegistryTest.scala
View file

@ -19,10 +19,10 @@ class ProducerRegistryTest extends WordSpec with MustMatchers with SharedCamelSy
"register a started SendProcessor for the producer, which is stopped when the actor is stopped" in {
val actorRef = newEmptyActor
val processor = registerProcessorFor(actorRef)
camel.awaitActivation(actorRef, 1 second)
camel.awaitActivation(actorRef, 5 second)
processor.isStarted must be(true)
system.stop(actorRef)
camel.awaitDeactivation(actorRef, 1 second)
camel.awaitDeactivation(actorRef, 5 second)
(processor.isStopping || processor.isStopped) must be(true)
}
"remove and stop the SendProcessor if the actorRef is registered" in {