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

=per #3820 Increase some test timeouts in persistence

Browse source 
* reproduced the problem with sleep in LeveldbStore
This commit is contained in:
Patrik Nordwall 2014-01-17 20:38:52 +01:00
parent 9a8766d871
commit 53ad96ed92
2 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-persistence/src/test/scala/akka/persistence/ChannelSpec.scala
View file

@ -189,7 +189,7 @@ abstract class ChannelSpec(config: Config) extends AkkaSpec(config) with Persist
1 to 3 foreach { i ⇒ channel ! Deliver(Persistent(i), system.deadLetters.path) } 1 to 3 foreach { i ⇒ channel ! Deliver(Persistent(i), system.deadLetters.path) }
probe.expectMsgAllOf(1, 2, 3) probe.expectMsgAllOf(10.seconds, 1, 2, 3)
system.stop(channel) system.stop(channel)
} }
} }

5
akka-persistence/src/test/scala/akka/persistence/EventsourcedSpec.scala
View file

@ -5,6 +5,7 @@
package akka.persistence package akka.persistence
import scala.collection.immutable.Seq import scala.collection.immutable.Seq
import scala.concurrent.duration._
import com.typesafe.config.Config import com.typesafe.config.Config
@ -310,7 +311,7 @@ abstract class EventsourcedSpec(config: Config) extends AkkaSpec(config) with Pe
expectMsg("c") expectMsg("c")
expectMsg("a") expectMsg("a")
} }
"support user stash operations with several stashed messages" in { "support user stash operations with several stashed messages" in within(10.seconds) {
val processor = namedProcessor[UserStashManyProcessor] val processor = namedProcessor[UserStashManyProcessor]
val n = 10 val n = 10
val cmds = 1 to n flatMap (_ ⇒ List(Cmd("a"), Cmd("b-1"), Cmd("b-2"), Cmd("c"))) val cmds = 1 to n flatMap (_ ⇒ List(Cmd("a"), Cmd("b-1"), Cmd("b-2"), Cmd("c")))
@ -320,7 +321,7 @@ abstract class EventsourcedSpec(config: Config) extends AkkaSpec(config) with Pe
processor ! GetState processor ! GetState
expectMsg((List("a-1", "a-2") ++ evts)) expectMsg((List("a-1", "a-2") ++ evts))
} }
"support user stash operations under failures" in { "support user stash operations under failures" in within(5.seconds) {
val processor = namedProcessor[UserStashFailureProcessor] val processor = namedProcessor[UserStashFailureProcessor]
val bs = 1 to 10 map ("b-" + _) val bs = 1 to 10 map ("b-" + _)
processor ! Cmd("a") processor ! Cmd("a")