Event refactoring

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

diff --git a/src/main/scala/gr/grnet/aquarium/service/IMEventProcessorService.scala b/src/main/scala/gr/grnet/aquarium/service/IMEventProcessorService.scala
index d144335..b3f8426 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/service/IMEventProcessorService.scala
+++ b/src/main/scala/gr/grnet/aquarium/service/IMEventProcessorService.scala
@@ -39,12 +39,11 @@ package gr.grnet.aquarium.service
 import gr.grnet.aquarium.actor.RouterRole
 import gr.grnet.aquarium.Configurator.Keys
 import gr.grnet.aquarium.store.LocalFSEventStore
-import gr.grnet.aquarium.actor.message.service.router.ProcessIMEvent
 import gr.grnet.aquarium.util.date.TimeHelpers
 import gr.grnet.aquarium.util.makeString
 import com.ckkloverdos.maybe._
-import gr.grnet.aquarium.store.memory.MemStore
-import gr.grnet.aquarium.event.im.{StdIMEvent, IMEventModel}
+import gr.grnet.aquarium.actor.message.event.ProcessIMEvent
+import gr.grnet.aquarium.event.model.im.{StdIMEvent, IMEventModel}
 
 /**
  * An event processor service for user events coming from the IM system
@@ -64,7 +63,7 @@ class IMEventProcessorService extends EventProcessorService[IMEventModel] {
   }
 
   override def existsInStore(event: IMEventModel) =
-    _configurator.imEventStore.findIMEventById(event.id).isJust
+    _configurator.imEventStore.findIMEventById(event.id).isDefined
 
   override def storeParsedEvent(event: IMEventModel, initialPayload: Array[Byte]) = {
     // 1. Store to local FS for debugging purposes.