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

fixed some tests

Browse source
This commit is contained in:
Michael Kober 2010-09-23 13:38:33 +02:00
parent dff036bdf9
commit 14c02ceeb1
3 changed files with 11 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-remote/src/test/scala/remote/ClientInitiatedRemoteActorSpec.scala
View file

@ -79,6 +79,8 @@ class ClientInitiatedRemoteActorSpec extends JUnitSuite {
@After
def finished() {
s1.shutdown
val s2 = RemoteServer.serverFor(HOSTNAME, PORT2)
if (s2.isDefined) s2.get.shutdown
RemoteClient.shutdownAll
Thread.sleep(1000)
}

2
akka-remote/src/test/scala/remote/ServerInitiatedRemoteActorSpec.scala
View file

@ -72,6 +72,8 @@ class ServerInitiatedRemoteActorSpec extends JUnitSuite {
def finished {
try {
server.shutdown
val s2 = RemoteServer.serverFor(HOSTNAME, PORT + 1)
if (s2.isDefined) s2.get.shutdown
RemoteClient.shutdownAll
Thread.sleep(1000)
} catch {

11
akka-remote/src/test/scala/ticket/Ticket434Spec.scala
View file

@ -14,12 +14,15 @@ import se.scalablesolutions.akka.remote.protocol.RemoteProtocol._
class Ticket434Spec extends Spec with ShouldMatchers {
val HOSTNAME = "localhost"
val PORT = 9991
describe("A server managed remote actor") {
it("should possible be use a custom service name containing ':'") {
val server = new RemoteServer().start("localhost", 9999)
it("can use a custom service name containing ':'") {
val server = new RemoteServer().start(HOSTNAME, PORT)
server.register("my:service", actorOf[RemoteActorSpecActorUnidirectional])
val actor = RemoteClient.actorFor("my:service", 5000L, "localhost", 9999)
val actor = RemoteClient.actorFor("my:service", 5000L, HOSTNAME, PORT)
actor ! "OneWay"
assert(RemoteActorSpecActorUnidirectional.latch.await(1, TimeUnit.SECONDS))
@ -31,7 +34,7 @@ class Ticket434Spec extends Spec with ShouldMatchers {
}
describe("The ActorInfoProtocol") {
it("should be possible to set the acor id and uuuid") {
it("sets the acor id and uuuid") {
val actorInfoBuilder = ActorInfoProtocol.newBuilder
.setUuid("unique-id")
.setId("some-id")