TestConductorSpec failure, final barrier missing, see #2440
This commit is contained in:
parent
4e4acef959
commit
7d1a9e1d29
1 changed files with 3 additions and 1 deletions
|
|
@ -16,7 +16,7 @@ import akka.testkit.ImplicitSender
|
||||||
import akka.testkit.LongRunningTest
|
import akka.testkit.LongRunningTest
|
||||||
import java.net.InetSocketAddress
|
import java.net.InetSocketAddress
|
||||||
import java.net.InetAddress
|
import java.net.InetAddress
|
||||||
import akka.remote.testkit.{STMultiNodeSpec, MultiNodeSpec, MultiNodeConfig}
|
import akka.remote.testkit.{ STMultiNodeSpec, MultiNodeSpec, MultiNodeConfig }
|
||||||
|
|
||||||
object TestConductorMultiJvmSpec extends MultiNodeConfig {
|
object TestConductorMultiJvmSpec extends MultiNodeConfig {
|
||||||
commonConfig(debugConfig(on = false))
|
commonConfig(debugConfig(on = false))
|
||||||
|
|
@ -104,6 +104,8 @@ class TestConductorSpec extends MultiNodeSpec(TestConductorMultiJvmSpec) with ST
|
||||||
runOn(master) {
|
runOn(master) {
|
||||||
testConductor.throttle(slave, master, Direction.Receive, -1).await
|
testConductor.throttle(slave, master, Direction.Receive, -1).await
|
||||||
}
|
}
|
||||||
|
|
||||||
|
enterBarrier("after")
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue