Revision 060b04bd src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala
b/src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala | ||
---|---|---|
190 | 190 |
|
191 | 191 |
private[this] def processResourceEventsAfterLastKnownUserState() { |
192 | 192 |
// Update the user state snapshot with fresh (ie not previously processed) events. |
193 |
aquarium.resourceEventStore.foreachResourceEventOccurredInPeriod( |
|
194 |
this._userStateModel.userID, |
|
195 |
this._userStateModel.latestResourceEventOccurredMillis, |
|
196 |
TimeHelpers.nowMillis() |
|
197 |
) |
|
193 | 198 |
} |
194 | 199 |
|
195 | 200 |
private[this] def makeUserStateMsgUpToDate() { |
Also available in: Unified diff