Merge pull request #1554 from akka/wip-3451-missing-identify-message-ban
Longer timeout in RemoteDeliverySpec #3451
This commit is contained in:
commit
98afb2bbd2
1 changed files with 3 additions and 1 deletions
|
|
@ -3,6 +3,8 @@
|
|||
*/
|
||||
package akka.remote
|
||||
|
||||
import scala.language.postfixOps
|
||||
|
||||
import scala.concurrent.duration._
|
||||
import com.typesafe.config.ConfigFactory
|
||||
import akka.actor.Actor
|
||||
|
|
@ -45,7 +47,7 @@ abstract class RemoteDeliverySpec
|
|||
|
||||
override def initialParticipants = roles.size
|
||||
|
||||
def identify(role: RoleName, actorName: String): ActorRef = {
|
||||
def identify(role: RoleName, actorName: String): ActorRef = within(10 seconds) {
|
||||
system.actorSelection(node(role) / "user" / actorName) ! Identify(actorName)
|
||||
expectMsgType[ActorIdentity].ref.get
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue