From 5d05d6197868850c8b10755ea49754ba3533419e Mon Sep 17 00:00:00 2001 From: Georgios Gousios Date: Mon, 12 Dec 2011 10:49:56 +0200 Subject: [PATCH] Send an appropriate event key --- .../test/scala/gr/grnet/aquarium/util/RandomEventGenerator.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/logic/src/test/scala/gr/grnet/aquarium/util/RandomEventGenerator.scala b/logic/src/test/scala/gr/grnet/aquarium/util/RandomEventGenerator.scala index 865b62a..3617a6d 100644 --- a/logic/src/test/scala/gr/grnet/aquarium/util/RandomEventGenerator.scala +++ b/logic/src/test/scala/gr/grnet/aquarium/util/RandomEventGenerator.scala @@ -36,7 +36,6 @@ package gr.grnet.aquarium.util */ import akka.amqp._ -import java.util.Date import gr.grnet.aquarium.logic.events.ResourceEvent import gr.grnet.aquarium.messaging.AkkaAMQP import util.Random @@ -88,7 +87,9 @@ trait RandomEventGenerator extends AkkaAMQP { val publisher = producer("aquarium") (1 to num).foreach { - n => publisher ! Message(nextResourceEvent.toBytes, "test.msg") + val event = nextResourceEvent + n => publisher ! Message(event.toBytes, + "event.%d.%s".format(event.cliendId, event.resource)) } } } \ No newline at end of file -- 1.7.10.4