svn commit: r1050722 - /incubator/esme/branches/lift-2.2/trunk/server/src/main/scala/org/apache/esme/actor/MessagePullActor.scala

[vd...@apache.org]

Author: vdichev
Date: Sat Dec 18 21:38:06 2010
New Revision: 1050722

URL: http://svn.apache.org/viewvc?rev=1050722&view=rev
Log:
Tighten messagePullActors key type to avoid future bugs

Modified:
    incubator/esme/branches/lift-2.2/trunk/server/src/main/scala/org/apache/esme/actor/MessagePullActor.scala

Modified: incubator/esme/branches/lift-2.2/trunk/server/src/main/scala/org/apache/esme/actor/MessagePullActor.scala
URL: http://svn.apache.org/viewvc/incubator/esme/branches/lift-2.2/trunk/server/src/main/scala/org/apache/esme/actor/MessagePullActor.scala?rev=1050722&r1=1050721&r2=1050722&view=diff
==============================================================================
--- incubator/esme/branches/lift-2.2/trunk/server/src/main/scala/org/apache/esme/actor/MessagePullActor.scala (original)
+++ incubator/esme/branches/lift-2.2/trunk/server/src/main/scala/org/apache/esme/actor/MessagePullActor.scala Sat Dec 18 21:38:06 2010
@@ -28,7 +28,7 @@ import com.twitter.ostrich.Stats
 
 object MessagePullActor extends LiftActor {
   
-  private var messagePullActors: Map[Any, LiftActor] = Map()
+  private var messagePullActors: Map[Long, LiftActor] = Map()
   
   protected def messageHandler = {
     case StartPullActor(obj, lastMessage, messageSource) => 
@@ -58,9 +58,9 @@ object MessagePullActor extends LiftActo
   private case object StartUp
   private case object ByeBye
   private case object FetchMessages
-  case class StartPullActor(any: Any, lastMessage: Option[Msg], messageSource: UniqueMessageSource)
-  case class StopPullActor(any: Any)
-  case class Fetch(any: Any)
+  case class StartPullActor(id: Long, lastMessage: Option[Msg], messageSource: UniqueMessageSource)
+  case class StopPullActor(id: Long)
+  case class Fetch(id: Long)
 
 
   private class MessagePullActor(