WIP Rework AMQP stuff
authorChristos KK Loverdos <loverdos@gmail.com>
Mon, 14 May 2012 14:37:27 +0000 (17:37 +0300)
committerChristos KK Loverdos <loverdos@gmail.com>
Mon, 14 May 2012 14:37:27 +0000 (17:37 +0300)
commit6107e07c91b11ce96c5dda4c4189cfd203c765ae
treef2e518bbc60553e2347092302259781e65ea495d
parent199695ce2756d822da5e9b0da24fe8751171b50b
WIP Rework AMQP stuff
19 files changed:
src/main/scala/gr/grnet/aquarium/Configurator.scala
src/main/scala/gr/grnet/aquarium/connector/handler/PayloadHandlerExecutor.scala [new file with mode: 0644]
src/main/scala/gr/grnet/aquarium/connector/handler/SynchronousPayloadHandlerExecutor.scala [new file with mode: 0644]
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/GenericPayloadHandler.scala
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/PayloadHandlerFutureExecutor.scala [new file with mode: 0644]
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/RabbitMQService.scala
src/main/scala/gr/grnet/aquarium/messaging/AkkaAMQP.scala [deleted file]
src/main/scala/gr/grnet/aquarium/service/AkkaService.scala
src/main/scala/gr/grnet/aquarium/service/EventBusService.scala
src/main/scala/gr/grnet/aquarium/service/EventProcessorService.scala [deleted file]
src/main/scala/gr/grnet/aquarium/service/IMEventProcessorService.scala [deleted file]
src/main/scala/gr/grnet/aquarium/service/ResourceEventProcessorService.scala [deleted file]
src/main/scala/gr/grnet/aquarium/service/SimpleLocalRoleableActorProviderService.scala
src/main/scala/gr/grnet/aquarium/util/RandomEventGenerator.scala [deleted file]
src/main/scala/gr/grnet/aquarium/util/ReflectHelpers.scala
src/main/scala/gr/grnet/aquarium/util/package.scala
src/test/scala/gr/grnet/aquarium/messaging/AkkaAMQPTest.scala [deleted file]
src/test/scala/gr/grnet/aquarium/store/mongodb/EventStoreTest.scala [deleted file]