From f98d61811ed46f10c89f2d18e2beea14b0417486 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonas=20Bon=C3=A9r?= Date: Tue, 5 Jan 2010 08:57:12 +0100 Subject: [PATCH] Updated pom.xml files to new dedicated Atmosphere and Jersey JARs --- akka-comet/pom.xml | 2 +- akka-core/src/main/scala/remote/RemoteServer.scala | 11 ++++++----- akka-rest/pom.xml | 7 +------ 3 files changed, 8 insertions(+), 12 deletions(-) diff --git a/akka-comet/pom.xml b/akka-comet/pom.xml index ae64f166f3..2d31a72c36 100644 --- a/akka-comet/pom.xml +++ b/akka-comet/pom.xml @@ -48,7 +48,7 @@ org.atmosphere atmosphere-runtime - ${atmosphere.version} + 0.5.v20100104 diff --git a/akka-core/src/main/scala/remote/RemoteServer.scala b/akka-core/src/main/scala/remote/RemoteServer.scala index 5b8e1f3e1b..580cbc48cd 100755 --- a/akka-core/src/main/scala/remote/RemoteServer.scala +++ b/akka-core/src/main/scala/remote/RemoteServer.scala @@ -46,7 +46,8 @@ import org.jboss.netty.handler.codec.compression.{ZlibEncoder, ZlibDecoder} object RemoteNode extends RemoteServer /** - * This object holds configuration variables. + * For internal use only. + * Holds configuration variables, remote actors, remote active objects and remote servers. * * @author Jonas Bonér */ @@ -90,7 +91,7 @@ object RemoteServer { private val remoteActorSets = new ConcurrentHashMap[Address, RemoteActorSet] private val remoteServers = new ConcurrentHashMap[Address, RemoteServer] - def actorsFor(remoteServerAddress: RemoteServer.Address): RemoteActorSet = { + private[akka] def actorsFor(remoteServerAddress: RemoteServer.Address): RemoteActorSet = { val set = remoteActorSets.get(remoteServerAddress) if (set ne null) set else { @@ -100,7 +101,7 @@ object RemoteServer { } } - def serverFor(hostname: String, port: Int): Option[RemoteServer] = { + private[remote] def serverFor(hostname: String, port: Int): Option[RemoteServer] = { val server = remoteServers.get(Address(hostname, port)) if (server eq null) None else Some(server) @@ -189,7 +190,7 @@ class RemoteServer extends Logging { } } -case class Codec(encoder : ChannelHandler,decoder : ChannelHandler) +case class Codec(encoder : ChannelHandler, decoder : ChannelHandler) /** * @author Jonas Bonér @@ -437,7 +438,7 @@ class RemoteServerHandler( newInstance } catch { case e => - log.error(e, "Could not create remote actor object instance") + log.error(e, "Could not create remote actor instance") throw e } } else actorOrNull diff --git a/akka-rest/pom.xml b/akka-rest/pom.xml index 812b73c862..4fc7f8c7cd 100644 --- a/akka-rest/pom.xml +++ b/akka-rest/pom.xml @@ -31,12 +31,7 @@ com.sun.jersey jersey-core - ${jersey.version} - - - com.sun.jersey - jersey-core - ${jersey.version} + 1.1.5-ea-20100104 com.sun.jersey