Making akka-cluster compile and tests green
This commit is contained in:
parent
52035402f8
commit
c37b97452b
3 changed files with 6 additions and 1 deletions
|
|
@ -4,6 +4,8 @@
|
||||||
|
|
||||||
package akka.cluster
|
package akka.cluster
|
||||||
|
|
||||||
|
import language.postfixOps
|
||||||
|
|
||||||
import akka.testkit.AkkaSpec
|
import akka.testkit.AkkaSpec
|
||||||
import akka.util.duration._
|
import akka.util.duration._
|
||||||
import akka.util.Duration
|
import akka.util.Duration
|
||||||
|
|
|
||||||
|
|
@ -4,6 +4,9 @@
|
||||||
|
|
||||||
package akka.cluster
|
package akka.cluster
|
||||||
|
|
||||||
|
import language.postfixOps
|
||||||
|
import language.reflectiveCalls
|
||||||
|
|
||||||
import akka.testkit.AkkaSpec
|
import akka.testkit.AkkaSpec
|
||||||
import akka.util.duration._
|
import akka.util.duration._
|
||||||
import akka.util.Duration
|
import akka.util.Duration
|
||||||
|
|
|
||||||
|
|
@ -216,7 +216,7 @@ private[akka] class ClientFSM(name: RoleName, controllerAddr: InetSocketAddress)
|
||||||
case AddressReply(node, addr) ⇒
|
case AddressReply(node, addr) ⇒
|
||||||
runningOp match {
|
runningOp match {
|
||||||
case Some((_, requester)) ⇒ requester ! addr
|
case Some((_, requester)) ⇒ requester ! addr
|
||||||
case None ⇒ log.warning("did not expect {}", op)
|
case None ⇒ log.warning("did not expect {}", op)
|
||||||
}
|
}
|
||||||
stay using d.copy(runningOp = None)
|
stay using d.copy(runningOp = None)
|
||||||
case t: ThrottleMsg ⇒
|
case t: ThrottleMsg ⇒
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue