minor fix in JSON message (UserActor-->Astakos , user balance)

diff --git a/src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala b/src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala
index f933964..fc644fb 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala
+++ b/src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala
@@ -381,7 +381,7 @@ class UserActor extends ReflectiveRoleableActor {
       computeBatch()
     }
     aquarium(Aquarium.EnvKeys.rabbitMQProducer).
-    sendMessage("{userid: \"%s\", state: %s}".
+    sendMessage("{\"userid\": \"%s\", \"state\": %s}".
                   format(this._userID,
                   this._workingUserState.totalCredits >= 0.0))
     DEBUG("Updated %s", this._workingUserState)

diff --git a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQProducer.scala b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQProducer.scala
index 11cff75..bb36eae 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQProducer.scala
+++ b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQProducer.scala
@@ -120,7 +120,7 @@ object RabbitMQProducer {
 
   def main(args: Array[String]) = {
     aquarium(Aquarium.EnvKeys.rabbitMQProducer).
-    sendMessage("{userid: \"pgerakios@grnet.gr\", state:true}")
+    sendMessage("{\"userid\": \"pgerakios@grnet.gr\", \"state\":true}")
     Console.err.println("Message sent")
     aquarium.stop()
     ()