From: Prodromos Gerakios Date: Fri, 27 Jul 2012 10:17:03 +0000 (+0300) Subject: minor fix in JSON message (UserActor-->Astakos , user balance) X-Git-Url: https://code.grnet.gr/git/aquarium/commitdiff_plain/5f8475e06857ac5abb59775d3698121230d08706?ds=sidebyside 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 --- 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 --- 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() ()