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

Muted exceptions sent to the TestEventListener in the ClusterSpec.

Browse source 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
Jonas Bonér 2012-03-16 00:17:43 +01:00
parent 1ae2c68d2f
commit 80da7b5e36
1 changed files with 10 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-cluster/src/test/scala/akka/cluster/ClusterSpec.scala
View file

@ -4,10 +4,13 @@
package akka.cluster
import akka.actor.ActorSystem
import akka.testkit.AkkaSpec
import akka.util._
import akka.util.duration._
import akka.testkit.AkkaSpec
import akka.testkit.TestEvent._
import akka.testkit.EventFilter
import com.typesafe.config.{ Config, ConfigFactory }
object ClusterSpec {
@ -49,7 +52,11 @@ abstract class ClusterSpec(_system: ActorSystem) extends AkkaSpec(_system) {
if (deadline.isOverdue) throw new IllegalStateException("Convergence could no be reached within " + maxWaitTime)
Thread.sleep(1000)
}
nodes.foreach(n ⇒ println("Converged: " + n.self + " == " + n.convergence.isDefined))
nodes foreach { n ⇒ println("Converged: " + n.self + " == " + n.convergence.isDefined) }
}
override def atStartup {
system.eventStream.publish(Mute(EventFilter[java.net.ConnectException]()))
system.eventStream.publish(Mute(EventFilter[java.nio.channels.ClosedChannelException]()))
}
}