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

renamed RemoteServerNode -> RemoteNode

Browse source
This commit is contained in:
jboner 2009-11-25 12:42:50 +01:00
parent 389182c1c6
commit 30d8dec0e7
5 changed files with 12 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-actors/src/main/scala/nio/RemoteServer.scala
View file

@ -24,7 +24,7 @@ import org.jboss.netty.handler.codec.compression.{ZlibEncoder, ZlibDecoder}
* Use this object if you need a single remote server on a specific node. * Use this object if you need a single remote server on a specific node.
* *
* <pre> * <pre>
* RemoteServerNode.start * RemoteNode.start
* </pre> * </pre>
* *
* If you need to create more than one, then you can use the RemoteServer: * If you need to create more than one, then you can use the RemoteServer:
@ -36,7 +36,7 @@ import org.jboss.netty.handler.codec.compression.{ZlibEncoder, ZlibDecoder}
* *
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a> * @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
*/ */
object RemoteServerNode extends RemoteServer object RemoteNode extends RemoteServer
/** /**
* This object holds configuration variables. * This object holds configuration variables.
@ -69,7 +69,7 @@ object RemoteServer {
* If you need to create more than one, then you can use the RemoteServer: * If you need to create more than one, then you can use the RemoteServer:
* *
* <pre> * <pre>
* RemoteServerNode.start * RemoteNode.start
* </pre> * </pre>
* *
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a> * @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>

5
akka-actors/src/test/scala/RemoteActorTest.scala
View file

@ -5,7 +5,8 @@ import junit.framework.TestCase
import org.scalatest.junit.JUnitSuite import org.scalatest.junit.JUnitSuite
import org.junit.Test import org.junit.Test
import se.scalablesolutions.akka.nio.{RemoteServerNode, RemoteServer, RemoteClient}
import se.scalablesolutions.akka.nio.{RemoteNode, RemoteServer, RemoteClient}
object Global { object Global {
var oneWay = "nada" var oneWay = "nada"
@ -32,7 +33,7 @@ class RemoteActorTest extends JUnitSuite {
akka.Config.config akka.Config.config
new Thread(new Runnable() { new Thread(new Runnable() {
def run = { def run = {
RemoteServerNode.start RemoteNode.start
} }
}).start }).start
Thread.sleep(1000) Thread.sleep(1000)

4
akka-actors/src/test/scala/RemoteSupervisorTest.scala
View file

@ -6,10 +6,10 @@ package se.scalablesolutions.akka.actor
import se.scalablesolutions.akka.serialization.BinaryString import se.scalablesolutions.akka.serialization.BinaryString
import se.scalablesolutions.akka.config.ScalaConfig._ import se.scalablesolutions.akka.config.ScalaConfig._
import se.scalablesolutions.akka.nio.{RemoteNode, RemoteClient, RemoteServer}
import org.scalatest.junit.JUnitSuite import org.scalatest.junit.JUnitSuite
import org.junit.Test import org.junit.Test
import se.scalablesolutions.akka.nio.{RemoteServerNode, RemoteClient, RemoteServer}
object Log { object Log {
var messageLog: String = "" var messageLog: String = ""
@ -25,7 +25,7 @@ class RemoteSupervisorTest extends JUnitSuite {
akka.Config.config akka.Config.config
new Thread(new Runnable() { new Thread(new Runnable() {
def run = { def run = {
RemoteServerNode.start RemoteNode.start
} }
}).start }).start
Thread.sleep(1000) Thread.sleep(1000)

4
akka-fun-test-java/src/test/java/se/scalablesolutions/akka/api/RemoteInMemoryStateTest.java
View file

@ -7,7 +7,7 @@ package se.scalablesolutions.akka.api;
import se.scalablesolutions.akka.Config; import se.scalablesolutions.akka.Config;
import se.scalablesolutions.akka.actor.ActiveObject; import se.scalablesolutions.akka.actor.ActiveObject;
import se.scalablesolutions.akka.config.ActiveObjectConfigurator; import se.scalablesolutions.akka.config.ActiveObjectConfigurator;
import se.scalablesolutions.akka.nio.RemoteServerNode; import se.scalablesolutions.akka.nio.RemoteNode;
import junit.framework.TestCase; import junit.framework.TestCase;
@ -17,7 +17,7 @@ public class RemoteInMemoryStateTest extends TestCase {
static { static {
new Thread(new Runnable() { new Thread(new Runnable() {
public void run() { public void run() {
RemoteServerNode.start(); RemoteNode.start();
} }
}).start(); }).start();
try { Thread.currentThread().sleep(1000); } catch (Exception e) {} try { Thread.currentThread().sleep(1000); } catch (Exception e) {}

4
akka-kernel/src/main/scala/Kernel.scala
View file

@ -12,7 +12,7 @@ import javax.ws.rs.core.UriBuilder
import java.io.File import java.io.File
import java.net.URLClassLoader import java.net.URLClassLoader
import se.scalablesolutions.akka.nio.RemoteServerNode import se.scalablesolutions.akka.nio.RemoteNode
import se.scalablesolutions.akka.util.Logging import se.scalablesolutions.akka.util.Logging
/** /**
@ -54,7 +54,7 @@ object Kernel extends Logging {
def startRemoteService = { def startRemoteService = {
// FIXME manage remote serve thread for graceful shutdown // FIXME manage remote serve thread for graceful shutdown
val remoteServerThread = new Thread(new Runnable() { val remoteServerThread = new Thread(new Runnable() {
def run = RemoteServerNode.start(applicationLoader) def run = RemoteNode.start(applicationLoader)
}, "Akka Remote Service") }, "Akka Remote Service")
remoteServerThread.start remoteServerThread.start
} }