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)
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()
()