Revision 5f8475e0

b/src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala
381 381 
      computeBatch()
382 382 
    }
383 383 
    aquarium(Aquarium.EnvKeys.rabbitMQProducer).
384 
    sendMessage("{userid: \"%s\", state: %s}".
384 
    sendMessage("{\"userid\": \"%s\", \"state\": %s}".
385 385 
                  format(this._userID,
386 386 
                  this._workingUserState.totalCredits >= 0.0))
387 387 
    DEBUG("Updated %s", this._workingUserState)
b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQProducer.scala
120 120 

  		





  121
  121
  
    
  def main(args: Array[String]) = {


  		





  122
  122
  
    
    aquarium(Aquarium.EnvKeys.rabbitMQProducer).


  		





  123
  
  
    
    sendMessage("{userid: \"pgerakios@grnet.gr\", state:true}")


  		





  
  123
  
    
    sendMessage("{\"userid\": \"pgerakios@grnet.gr\", \"state\":true}")


  		





  124
  124
  
    
    Console.err.println("Message sent")


  		





  125
  125
  
    
    aquarium.stop()


  		





  126
  126
  
    
    ()


  		












Also available in:
  Unified diff