One state to rule them all

[aquarium] / src / main / scala / gr / grnet / aquarium / message / avro / MessageFactory.scala

diff --git a/src/main/scala/gr/grnet/aquarium/message/avro/MessageFactory.scala b/src/main/scala/gr/grnet/aquarium/message/avro/MessageFactory.scala
index 9d34fef..dbf7dd8 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/message/avro/MessageFactory.scala
+++ b/src/main/scala/gr/grnet/aquarium/message/avro/MessageFactory.scala
@@ -360,6 +360,15 @@ object MessageFactory {
       build()
   }
 
       build()
   }
 

+  /**
+   * Creates the initial (from the UserActor's perspective) user state.
+   * This may not be the very first user state ever, so we do not set `isFirst`.
+   * @param userID
+   * @param initialCredits
+   * @param occurredMillis
+   * @param originalID
+   * @return
+   */

   def newInitialUserStateMsg(
       userID: String,
       initialCredits: Real,
   def newInitialUserStateMsg(
       userID: String,
       initialCredits: Real,

@@ -379,8 +388,8 @@ object MessageFactory {
     msg.setLatestUpdateMillis(java.lang.Long.valueOf(occurredMillis))
     msg.setInStoreID(null)
     msg.setOriginalID(originalID)
     msg.setLatestUpdateMillis(java.lang.Long.valueOf(occurredMillis))
     msg.setInStoreID(null)
     msg.setOriginalID(originalID)

-    msg.setStateOfResources(new java.util.HashMap())
-    msg.setWalletEntries(new java.util.ArrayList[WalletEntryMsg]())
+    msg.setStateOfResources(newJMap)
+    msg.setWalletEntries(newJList)

     msg
   }
 }
     msg
   }
 }