From db0ff242a9b1b85de60598dc73759f6439d4d89a Mon Sep 17 00:00:00 2001
From: Viktor Klang <viktor.klang@gmail.com>
Date: Thu, 9 Sep 2010 20:31:05 +0200
Subject: [PATCH 1/3] Moving the Atmosphere AkkaBroadcaster dispatcher to be
 shared

---
 akka-http/src/main/scala/AkkaBroadcaster.scala | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/akka-http/src/main/scala/AkkaBroadcaster.scala b/akka-http/src/main/scala/AkkaBroadcaster.scala
index 8f724ff445..ca5abc6f1d 100644
--- a/akka-http/src/main/scala/AkkaBroadcaster.scala
+++ b/akka-http/src/main/scala/AkkaBroadcaster.scala
@@ -9,10 +9,13 @@ import se.scalablesolutions.akka.actor.Actor._
 import se.scalablesolutions.akka.actor.Actor
 import se.scalablesolutions.akka.dispatch.Dispatchers
 
-class AkkaBroadcaster extends org.atmosphere.jersey.JerseyBroadcaster {
-  name = classOf[AkkaBroadcaster].getName
-
+object AkkaBroadcaster {
   val broadcasterDispatcher = Dispatchers.fromConfig("akka.rest.comet-dispatcher")
+}
+
+class AkkaBroadcaster extends org.atmosphere.jersey.JerseyBroadcaster {
+  import AkkaBroadcaster._
+  name = classOf[AkkaBroadcaster].getName
 
   //FIXME should be supervised
   val caster = actorOf(new Actor {

From bae292a1f8de3f41989af610a07c53645ad4ae96 Mon Sep 17 00:00:00 2001
From: Viktor Klang <viktor.klang@gmail.com>
Date: Thu, 9 Sep 2010 23:14:33 +0200
Subject: [PATCH 2/3] Added findValue to Index

---
 akka-actor/src/main/scala/actor/ActorRegistry.scala | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/akka-actor/src/main/scala/actor/ActorRegistry.scala b/akka-actor/src/main/scala/actor/ActorRegistry.scala
index 6c6056221a..f3a479e6fd 100644
--- a/akka-actor/src/main/scala/actor/ActorRegistry.scala
+++ b/akka-actor/src/main/scala/actor/ActorRegistry.scala
@@ -205,6 +205,14 @@ class Index[K <: AnyRef,V <: AnyRef : Manifest] {
      set foreach fun
   }
 
+  def findValue(key: K)(f: (V) => Boolean): Option[V] = {
+    val set = container get key
+    if (set ne null)
+     set.iterator.find(f)
+    else
+     None
+  }
+
   def foreach(fun: (K,V) => Unit) {
     container.entrySet foreach {
       (e) => e.getValue.foreach(fun(e.getKey,_))

From 63d0f4376f070eee221c37616a376b176393598e Mon Sep 17 00:00:00 2001
From: Martin Krasser <krasserm@googlemail.com>
Date: Fri, 10 Sep 2010 10:22:46 +0200
Subject: [PATCH 3/3] Removed logback config files from akka-actor and
 akka-remote and use only those in $AKKA_HOME/config (see also ticket #410).

---
 akka-actor/src/main/resources/logback.xml     | 31 -------------------
 .../src/test/resources/logback-test.xml       | 21 -------------
 .../src/test/resources/logback-test.xml       | 21 -------------
 3 files changed, 73 deletions(-)
 delete mode 100644 akka-actor/src/main/resources/logback.xml
 delete mode 100644 akka-actor/src/test/resources/logback-test.xml
 delete mode 100644 akka-remote/src/test/resources/logback-test.xml

diff --git a/akka-actor/src/main/resources/logback.xml b/akka-actor/src/main/resources/logback.xml
deleted file mode 100644
index 4635396601..0000000000
--- a/akka-actor/src/main/resources/logback.xml
+++ /dev/null
@@ -1,31 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- For assistance related to logback-translator or configuration  -->
-<!-- files in general, please contact the logback user mailing list -->
-<!-- at http://www.qos.ch/mailman/listinfo/logback-user             -->
-<!--                                                                -->
-<!-- For professional support please see                            -->
-<!--    http://www.qos.ch/shop/products/professionalSupport         -->
-<!--                                                                -->
-        <!-- FOR AKKA INTERNAL USE ONLY -->
-<configuration scan="false" debug="false">
-  <appender name="stdout" class="ch.qos.logback.core.ConsoleAppender">
-    <encoder>
-      <pattern>[%4p] [%d{ISO8601}] [%t] %c{1}: %m%n</pattern>
-    </encoder>
-  </appender>
-  <appender name="R" class="ch.qos.logback.core.rolling.RollingFileAppender">
-    <File>./logs/akka.log</File>
-    <encoder>
-      <pattern>[%4p] [%d{ISO8601}] [%t] %c{1}: %m%n</pattern>
-    </encoder>
-    <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
-      <fileNamePattern>./logs/akka.log.%d{yyyy-MM-dd-HH}</fileNamePattern>
-    </rollingPolicy>
-  </appender>
-  <logger name="se.scalablesolutions" level="DEBUG"/>
-  <root level="INFO">
-    <appender-ref ref="stdout"/>
-    <appender-ref ref="R"/>
-  </root>
-</configuration>
diff --git a/akka-actor/src/test/resources/logback-test.xml b/akka-actor/src/test/resources/logback-test.xml
deleted file mode 100644
index 78eae40ec4..0000000000
--- a/akka-actor/src/test/resources/logback-test.xml
+++ /dev/null
@@ -1,21 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- For assistance related to logback-translator or configuration  -->
-<!-- files in general, please contact the logback user mailing list -->
-<!-- at http://www.qos.ch/mailman/listinfo/logback-user             -->
-<!--                                                                -->
-<!-- For professional support please see                            -->
-<!--    http://www.qos.ch/shop/products/professionalSupport         -->
-<!--                                                                -->
-<configuration scan="false" debug="false">
-  <!-- FOR AKKA INTERNAL USE ONLY -->
-  <appender name="stdout" class="ch.qos.logback.core.ConsoleAppender">
-    <encoder>
-      <pattern>[%4p] [%d{ISO8601}] [%t] %c{1}: %m%n</pattern>
-    </encoder>
-  </appender>
-  <logger name="se.scalablesolutions" level="DEBUG"/>
-  <root level="DEBUG">
-    <appender-ref ref="stdout"/>
-  </root>
-</configuration>
diff --git a/akka-remote/src/test/resources/logback-test.xml b/akka-remote/src/test/resources/logback-test.xml
deleted file mode 100644
index 78eae40ec4..0000000000
--- a/akka-remote/src/test/resources/logback-test.xml
+++ /dev/null
@@ -1,21 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- For assistance related to logback-translator or configuration  -->
-<!-- files in general, please contact the logback user mailing list -->
-<!-- at http://www.qos.ch/mailman/listinfo/logback-user             -->
-<!--                                                                -->
-<!-- For professional support please see                            -->
-<!--    http://www.qos.ch/shop/products/professionalSupport         -->
-<!--                                                                -->
-<configuration scan="false" debug="false">
-  <!-- FOR AKKA INTERNAL USE ONLY -->
-  <appender name="stdout" class="ch.qos.logback.core.ConsoleAppender">
-    <encoder>
-      <pattern>[%4p] [%d{ISO8601}] [%t] %c{1}: %m%n</pattern>
-    </encoder>
-  </appender>
-  <logger name="se.scalablesolutions" level="DEBUG"/>
-  <root level="DEBUG">
-    <appender-ref ref="stdout"/>
-  </root>
-</configuration>