Configure aquarium when creating the user actor

diff --git a/src/main/scala/gr/grnet/aquarium/service/FinagleRESTService.scala b/src/main/scala/gr/grnet/aquarium/service/FinagleRESTService.scala
index 5da6ecd..1b635f6 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/service/FinagleRESTService.scala
+++ b/src/main/scala/gr/grnet/aquarium/service/FinagleRESTService.scala
@@ -236,7 +236,7 @@ class FinagleRESTService extends Lifecycle with AquariumAwareSkeleton with Confi
       val millis = TimeHelpers.nowMillis()
       val uri = request.getUri
       val method = request.getMethod
-      logger.debug("%s %s".format(method, uri))
+      logger.debug("%s %s %s".format(method, request.getProtocolVersion, uri))
 
       uri match {
         case RESTPaths.PingPath() ⇒

diff --git a/src/main/scala/gr/grnet/aquarium/service/SimpleLocalRoleableActorProviderService.scala b/src/main/scala/gr/grnet/aquarium/service/SimpleLocalRoleableActorProviderService.scala
index 06291d7..beb0595 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/service/SimpleLocalRoleableActorProviderService.scala
+++ b/src/main/scala/gr/grnet/aquarium/service/SimpleLocalRoleableActorProviderService.scala
@@ -42,6 +42,7 @@ import java.util.concurrent.ConcurrentHashMap
 import gr.grnet.aquarium.util.Loggable
 import gr.grnet.aquarium.actor.message.config.{AquariumPropertiesLoaded, ActorProviderConfigured}
 import gr.grnet.aquarium.actor._
+import gr.grnet.aquarium.service.event.AquariumCreatedEvent
 
 /**
  * All actors are provided locally.
@@ -77,7 +78,9 @@ class SimpleLocalRoleableActorProviderService
 
   private[this] def _newActor(role: ActorRole): ActorRef = {
     val actorFactory = (_class: Class[_ <: RoleableActor]) ⇒ {
-      aquarium.newInstance(_class, _class.getName)
+      val actor = aquarium.newInstance(_class, _class.getName)
+      actor.awareOfAquariumEx(AquariumCreatedEvent(aquarium))
+      actor
     }
 
     val actorRef = akka.actor.Actor.actorOf(actorFactory(role.actorType)).start()