converted tabs to spaces

This commit is contained in:
Jonas Bonér 2010-02-15 18:41:20 +01:00
parent 96ef70d343
commit dd939a00e7
15 changed files with 26 additions and 26 deletions

View file

@ -34,7 +34,7 @@
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>2.5</version>
</dependency>
</dependency>
<dependency>
<groupId>org.atmosphere</groupId>
<artifactId>atmosphere-annotations</artifactId>

View file

@ -11,9 +11,9 @@ class AkkaBroadcaster extends org.atmosphere.jersey.JerseyBroadcaster {
name = classOf[AkkaBroadcaster].getName
val caster = new Actor {
def receive = { case f : Function0[_] => f() }
start
def receive = { case f : Function0[_] => f() }
start
}
override def destroy {

View file

@ -54,17 +54,17 @@ trait BootableCometActorService extends Bootable with Logging {
t.setAdapter(adapter)
t.setEnableAsyncExecution(true)
t.setAsyncHandler(ah)
t.listen
t }
t.listen
t }
log.info("REST service started successfully. Listening to port [%s]", REST_PORT)
}
}
abstract override def onUnload = {
super.onUnload
if (jerseySelectorThread.isDefined) {
super.onUnload
if (jerseySelectorThread.isDefined) {
log.info("Shutting down REST service (Jersey)")
jerseySelectorThread.get.stopEndpoint
}

0
akka-core/src/main/resources/META-INF/aop.xml Executable file → Normal file
View file

View file

@ -37,8 +37,8 @@ trait BootableRemoteActorService extends Bootable with Logging {
}
abstract override def onUnload = {
super.onUnload
if (remoteServerThread.isAlive) {
super.onUnload
if (remoteServerThread.isAlive) {
log.info("Shutting down Remote Actors Service")
RemoteNode.shutdown
remoteServerThread.join(1000)

View file

@ -323,12 +323,12 @@ private[collection] class FullNode[K, +V](shift: Int)(table: Array[Node[K, V]])
val node = (table(i)(shift + 5, key, hash) = value)
if (node == table(i)) this else {
val newTable = new Array[Node[K, A]](32)
Array.copy(table, 0, newTable, 0, 32)
newTable(i) = node
new FullNode(shift)(newTable)
val newTable = new Array[Node[K, A]](32)
Array.copy(table, 0, newTable, 0, 32)
newTable(i) = node
new FullNode(shift)(newTable)
}
}

View file

@ -32,10 +32,10 @@ import stm.Transaction
*
* scala> res0()
* java.lang.RuntimeException: Lets see what happens here...
* at ResultOrFailure.apply(RefExcept.scala:11)
* at .<init>(<console>:6)
* at .<clinit>(<console>)
* at Re...
* at ResultOrFailure.apply(RefExcept.scala:11)
* at .<init>(<console>:6)
* at .<clinit>(<console>)
* at Re...
* </pre>
*
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>

View file

@ -8,7 +8,7 @@ import se.scalablesolutions.akka.config.*;
import se.scalablesolutions.akka.config.ActiveObjectConfigurator;
import static se.scalablesolutions.akka.config.JavaConfig.*;
import se.scalablesolutions.akka.actor.*;
import se.scalablesolutions.akka.Kernel;
import se.scalablesolutions.akka.Kernel;
import junit.framework.TestCase;

0
akka-fun-test-java/testng.xml Executable file → Normal file
View file

0
akka-kernel/pom.xml Executable file → Normal file
View file

View file

@ -34,12 +34,12 @@ object Patterns {
) */
def dispatcherActor(routing : PF[Any,Actor], msgTransformer : (Any) => Any) : Actor = new Actor with Dispatcher {
override def transform(msg : Any) = msgTransformer(msg)
override def transform(msg : Any) = msgTransformer(msg)
def routes = routing
}
def dispatcherActor(routing : PF[Any,Actor]) : Actor = new Actor with Dispatcher {
def routes = routing
def routes = routing
}
def loggerActor(actorToLog : Actor, logger : (Any) => Unit) : Actor = dispatcherActor (

View file

@ -27,7 +27,7 @@
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>2.5</version>
</dependency>
</dependency>
<dependency>
<groupId>com.sun.jersey</groupId>
<artifactId>jersey-core</artifactId>

View file

0
akka-util-java/pom.xml Executable file → Normal file
View file

2
pom.xml Executable file → Normal file
View file

@ -93,7 +93,7 @@
<timezone>+1</timezone>
<email>viktor.klang [REMOVE] AT gmail DOT com</email>
<roles>
<role>Apostle</role>
<role>Apostle</role>
</roles>
</developer>
</developers>