WIP integrating Avro-style policy messages

[aquarium] / src / main / scala / gr / grnet / aquarium / connector / rabbitmq / RabbitMQProducer.scala

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 2c70a66..d56f648 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQProducer.scala
+++ b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQProducer.scala
@@ -222,7 +222,7 @@ object RabbitMQProducer  {
   def main(args: Array[String]) = {
     val propsfile = new FileStreamResource(new File("aquarium.properties"))
     var _props: Props = Props(propsfile)(StdConverters.AllConverters).getOr(Props()(StdConverters.AllConverters))
-    val aquarium = new AquariumBuilder(_props, ResourceLocator.DefaultPolicyModel).
+    val aquarium = new AquariumBuilder(_props, ResourceLocator.DefaultPolicyMsg).
     update(Aquarium.EnvKeys.storeProvider, new MemStoreProvider).
     update(Aquarium.EnvKeys.eventsStoreFolder, Some(new File(".."))).
     build()