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)
