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

Fixed broken tests: NewLeaderChangeListenerMultiJvmSpec and ReplicationTransactionLogWriteThroughNoSnapshotMultiJvmSpec.

Browse source 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
Jonas Bonér 2011-08-18 15:53:08 +02:00
parent 67e0c59982
commit ea95588a50
4 changed files with 14 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster/src/main/scala/akka/cluster/Cluster.scala
View file

@ -531,6 +531,8 @@ class DefaultClusterNode private[akka] (
}
private[cluster] def publish(change: ChangeNotification) {
println("=============================================================== PUBLISH")
println("=======>>> change: " + change)
changeListeners.iterator.foreach(_.notify(change, this))
}