WIP Reowrk AMQP stuff and introduce the event bus

[aquarium] / src / main / scala / gr / grnet / aquarium / service / ResourceEventProcessorService.scala

diff --git a/src/main/scala/gr/grnet/aquarium/service/ResourceEventProcessorService.scala b/src/main/scala/gr/grnet/aquarium/service/ResourceEventProcessorService.scala
index 1cccf99..8dd46ea 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/service/ResourceEventProcessorService.scala
+++ b/src/main/scala/gr/grnet/aquarium/service/ResourceEventProcessorService.scala
@@ -41,7 +41,7 @@ import com.ckkloverdos.maybe.Maybe
 import gr.grnet.aquarium.util.date.TimeHelpers
 import gr.grnet.aquarium.event.model.resource.{StdResourceEvent, ResourceEventModel}
 import gr.grnet.aquarium.actor.message.event.ProcessResourceEvent
-import gr.grnet.aquarium.event.amqp.AMQPService.{AMQPKeys ⇒ Keys}
+import gr.grnet.aquarium.connector.rabbitmq.service.RabbitMQService.{RabbitMQConfKeys ⇒ Keys}
 
 /**
  * An event processor service for resource events
@@ -103,7 +103,7 @@ final class ResourceEventProcessorService extends EventProcessorService[Resource
   def start() {
     logStarting()
     val (ms0, ms1, _) = TimeHelpers.timed {
-      declareQueues(Keys.amqp_resevents_queues)
+      declareQueues(Keys.amqp_rcevents_queues)
     }
     logStarted(ms0, ms1)
   }