incubator-esme-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vdic...@apache.org
Subject svn commit: r805985 - /incubator/esme/trunk/server/src/main/scala/org/apache/esme/actor/UserActor.scala
Date Wed, 19 Aug 2009 21:30:24 GMT
Author: vdichev
Date: Wed Aug 19 21:30:24 2009
New Revision: 805985

URL: http://svn.apache.org/viewvc?rev=805985&view=rev
Log:
Update cached resend info in message mailbox.

Modified:
    incubator/esme/trunk/server/src/main/scala/org/apache/esme/actor/UserActor.scala

Modified: incubator/esme/trunk/server/src/main/scala/org/apache/esme/actor/UserActor.scala
URL: http://svn.apache.org/viewvc/incubator/esme/trunk/server/src/main/scala/org/apache/esme/actor/UserActor.scala?rev=805985&r1=805984&r2=805985&view=diff
==============================================================================
--- incubator/esme/trunk/server/src/main/scala/org/apache/esme/actor/UserActor.scala (original)
+++ incubator/esme/trunk/server/src/main/scala/org/apache/esme/actor/UserActor.scala Wed Aug
19 21:30:24 2009
@@ -199,6 +199,10 @@
           Mailbox.find(By(Mailbox.message, msg),
                        By(Mailbox.user, userId)).foreach { m =>
                          m.resent(true).save
+                         _mailbox = _mailbox.map {
+                           case (`msgId`, r, _) => (msgId, r, true)
+                           case x => x
+                         }
                          listeners.foreach(_ ! Resend(msgId))
                        }
           for (id <- followers)



Mime
View raw message