Expose some debugging facilities in Aquarium class

diff --git a/src/main/scala/gr/grnet/aquarium/Aquarium.scala b/src/main/scala/gr/grnet/aquarium/Aquarium.scala
index aeaaffb..efa0b1b 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/Aquarium.scala
+++ b/src/main/scala/gr/grnet/aquarium/Aquarium.scala
@@ -42,7 +42,7 @@ import com.ckkloverdos.props.Props
 import com.ckkloverdos.convert.Converters.{DefaultConverters => TheDefaultConverters}
 
 import gr.grnet.aquarium.service._
-import gr.grnet.aquarium.util.{Lifecycle, Loggable, shortNameOfClass}
+import gr.grnet.aquarium.util.{Lifecycle, Loggable, shortNameOfClass, shortClassNameOf}
 import gr.grnet.aquarium.store._
 import gr.grnet.aquarium.connector.rabbitmq.service.RabbitMQService
 import gr.grnet.aquarium.converter.StdConverters
@@ -64,6 +64,18 @@ final class Aquarium(val props: Props) extends Lifecycle with Loggable {
 
   def isStopping() = _isStopping.get()
 
+  def debug(client: AnyRef, fmt: String, args: Any*) = {
+    logger.debug("[%s] %s".format(shortClassNameOf(client), fmt.format(args: _*)))
+  }
+
+  def info(client: AnyRef, fmt: String, args: Any*) = {
+    logger.info("[%s] %s".format(shortClassNameOf(client), fmt.format(args: _*)))
+  }
+
+  def warn(client: AnyRef, fmt: String, args: Any*) = {
+    logger.warn("[%s] %s".format(shortClassNameOf(client), fmt.format(args: _*)))
+  }
+
   /**
    * Reflectively provide a new instance of a class and configure it appropriately.
    */