Caught a typo

Signed-off-by: Christos KK Loverdos <loverdos@gmail.com>

diff --git a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/RabbitMQService.scala b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/RabbitMQService.scala
index a15b62a..bdb8cbb 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/RabbitMQService.scala
+++ b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/RabbitMQService.scala
@@ -250,7 +250,7 @@ class RabbitMQService extends Loggable with Lifecycle with Configurable {
   }
 
   def start() = {
-    aquarium.eventBus.addSubsciber(this)
+    aquarium.eventBus.addSubscriber(this)
 
     safeStart()
   }

diff --git a/src/main/scala/gr/grnet/aquarium/service/EventBusService.scala b/src/main/scala/gr/grnet/aquarium/service/EventBusService.scala
index adab928..1753cce 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/service/EventBusService.scala
+++ b/src/main/scala/gr/grnet/aquarium/service/EventBusService.scala
@@ -69,7 +69,7 @@ class EventBusService extends Loggable with Lifecycle with Configurable {
   }
 
   def start() = {
-    this addSubsciber this // Wow!
+    this addSubscriber this // Wow!
   }
 
   def stop() = synchronized {
@@ -89,12 +89,12 @@ class EventBusService extends Loggable with Lifecycle with Configurable {
     asyncBus.post(event)
   }
 
-  def removeSubsciber[A <: AnyRef](subscriber: A): Unit = synchronized {
+  def removeSubscriber[A <: AnyRef](subscriber: A): Unit = synchronized {
     subscribers.remove(subscriber)
     asyncBus.unregister(subscriber)
   }
 
-  def addSubsciber[A <: AnyRef](subscriber: A): Unit = synchronized {
+  def addSubscriber[A <: AnyRef](subscriber: A): Unit = synchronized {
     subscribers.add(subscriber)
     asyncBus.register(subscriber)
   }