Permalink
Browse files

remove postfixOps warnings in remote tests

  • Loading branch information...
1 parent a367ad0 commit 8c537fbc37442cea945ae98dc21794391ada1b74 @rkuhn rkuhn committed Jan 3, 2013
@@ -210,7 +210,7 @@ class RemotingSpec extends AkkaSpec(RemotingSpec.cfg) with ImplicitSender with D
r.path.toString must be ===
s"udp.akka://remote-sys@localhost:${port(other, "udp")}/remote/udp.akka/RemotingSpec@localhost:${port(system, "udp")}/user/zagzag"
r ! 42
- expectMsg(10 seconds, 42)
+ expectMsg(10.seconds, 42)
EventFilter[Exception]("crash", occurrences = 1).intercept {
r ! new Exception("crash")
}(other)
@@ -226,7 +226,7 @@ class RemotingSpec extends AkkaSpec(RemotingSpec.cfg) with ImplicitSender with D
r.path.toString must be ===
s"tcp.ssl.akka://remote-sys@localhost:${port(other, "tcp.ssl")}/remote/tcp.ssl.akka/RemotingSpec@localhost:${port(system, "tcp.ssl")}/user/roghtaar"
r ! 42
- expectMsg(10 seconds, 42)
+ expectMsg(10.seconds, 42)
EventFilter[Exception]("crash", occurrences = 1).intercept {
r ! new Exception("crash")
}(other)
@@ -202,7 +202,7 @@ class AkkaProtocolSpec extends AkkaSpec("""akka.actor.provider = "akka.remote.Re
codec,
failureDetector)))
- Await.result(statusPromise.future, 3 seconds) match {
+ Await.result(statusPromise.future, 3.seconds) match {
case h: AssociationHandle
h.remoteAddress must be === remoteAkkaAddress
h.localAddress must be === localAkkaAddress
@@ -241,7 +241,7 @@ class AkkaProtocolSpec extends AkkaSpec("""akka.actor.provider = "akka.remote.Re
// finish connection by sending back a payload
reader ! testPayload
- Await.result(statusPromise.future, 3 seconds) match {
+ Await.result(statusPromise.future, 3.seconds) match {
case h: AssociationHandle
h.remoteAddress must be === remoteAkkaAddress
h.localAddress must be === localAkkaAddress
@@ -315,7 +315,7 @@ class AkkaProtocolSpec extends AkkaSpec("""akka.actor.provider = "akka.remote.Re
codec,
failureDetector)))
- Await.result(statusPromise.future, 3 seconds) match {
+ Await.result(statusPromise.future, 3.seconds) match {
case h: AssociationHandle
h.remoteAddress must be === remoteAkkaAddress
h.localAddress must be === localAkkaAddress
@@ -341,7 +341,7 @@ class AkkaProtocolSpec extends AkkaSpec("""akka.actor.provider = "akka.remote.Re
codec,
failureDetector)))
- val wrappedHandle = Await.result(statusPromise.future, 3 seconds) match {
+ val wrappedHandle = Await.result(statusPromise.future, 3.seconds) match {
case h: AssociationHandle
h.remoteAddress must be === remoteAkkaAddress
h.localAddress must be === localAkkaAddress
@@ -379,7 +379,7 @@ class AkkaProtocolSpec extends AkkaSpec("""akka.actor.provider = "akka.remote.Re
// Finish association with a heartbeat -- pushes state out of WaitActivity
reader ! testHeartbeat
- val wrappedHandle = Await.result(statusPromise.future, 3 seconds) match {
+ val wrappedHandle = Await.result(statusPromise.future, 3.seconds) match {
case h: AssociationHandle
h.remoteAddress must be === remoteAkkaAddress
h.localAddress must be === localAkkaAddress
@@ -412,7 +412,7 @@ class AkkaProtocolSpec extends AkkaSpec("""akka.actor.provider = "akka.remote.Re
codec,
failureDetector)))
- val wrappedHandle = Await.result(statusPromise.future, 3 seconds) match {
+ val wrappedHandle = Await.result(statusPromise.future, 3.seconds) match {
case h: AssociationHandle
h.remoteAddress must be === remoteAkkaAddress
h.localAddress must be === localAkkaAddress
@@ -448,7 +448,7 @@ class AkkaProtocolSpec extends AkkaSpec("""akka.actor.provider = "akka.remote.Re
codec,
failureDetector)))
- val wrappedHandle = Await.result(statusPromise.future, 3 seconds) match {
+ val wrappedHandle = Await.result(statusPromise.future, 3.seconds) match {
case h: AssociationHandle
h.remoteAddress must be === remoteAkkaAddress
h.localAddress must be === localAkkaAddress
@@ -79,7 +79,7 @@ class AkkaProtocolStressTest extends AkkaSpec(configA) with ImplicitSender with
"guarantee at-most-once delivery and message ordering despite packet loss" taggedAs TimingTest in {
val tester = system.actorOf(Props(new SequenceVerifier(here, self))) ! "start"
- expectMsgPF(30 seconds) {
+ expectMsgPF(30.seconds) {
case (received: Int, lost: Int)
log.debug(s" ######## Received ${received - lost} messages from ${received} ########")
}
@@ -70,10 +70,10 @@ class ThrottlerTransportAdapterSpec extends AkkaSpec(configA) with ImplicitSende
"maintain average message rate" taggedAs TimingTest in {
Await.result(
system.asInstanceOf[ExtendedActorSystem].provider.asInstanceOf[RemoteActorRefProvider].transport
- .managementCommand(SetThrottle(Address("akka", "systemB", "localhost", rootB.address.port.get), Direction.Send, TokenBucket(200, 500, 0, 0))), 3 seconds)
+ .managementCommand(SetThrottle(Address("akka", "systemB", "localhost", rootB.address.port.get), Direction.Send, TokenBucket(200, 500, 0, 0))), 3.seconds)
val tester = system.actorOf(Props(new ThrottlingTester(here, self))) ! "start"
- expectMsgPF((TotalTime + 3) seconds) {
+ expectMsgPF((TotalTime + 3).seconds) {
case time: Long log.warning("Total time of transmission: " + NANOSECONDS.toSeconds(time))
}
system.eventStream.publish(TestEvent.Mute(

0 comments on commit 8c537fb

Please sign in to comment.