AMQP stuff is now in good shape
authorChristos KK Loverdos <loverdos@gmail.com>
Fri, 18 May 2012 11:30:47 +0000 (14:30 +0300)
committerChristos KK Loverdos <loverdos@gmail.com>
Fri, 18 May 2012 11:30:47 +0000 (14:30 +0300)
commit6a8f128435ef8936cb3c8e8b21696154cd173878
tree51ad722472b6e0883df4c5563b4bbdd4f3036047
parent354597acb567b3fb3efd7cb73265fe8523ac2948
AMQP stuff is now in good shape

We have:
- Automatic pings for rabbitmq consumers.
- Automatic pings for consumer-related event stores.
- When a store goes down, all the relevant consumers stop accepting
messagges, since we must alwaysd be able to store an event.
- Automatic reconnections for failed consumers.
- Automatic reconnections for failed event stores.

Still needed, but will made later:
- RabbitMQ producer functionality.
21 files changed:
src/main/resources/aquarium.properties
src/main/scala/gr/grnet/aquarium/Aquarium.scala
src/main/scala/gr/grnet/aquarium/actor/service/user/UserActorCache.scala
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/conf/RabbitMQConsumerConf.scala
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/GenericPayloadHandler.scala
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/PayloadHandlerFutureExecutor.scala
src/main/scala/gr/grnet/aquarium/connector/rabbitmq/service/RabbitMQService.scala
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/RESTActorService.scala
src/main/scala/gr/grnet/aquarium/service/SimpleLocalRoleableActorProviderService.scala
src/main/scala/gr/grnet/aquarium/service/SimpleTimerService.scala
src/main/scala/gr/grnet/aquarium/service/StoreWatcherService.scala [new file with mode: 0644]
src/main/scala/gr/grnet/aquarium/service/TimerService.scala
src/main/scala/gr/grnet/aquarium/service/event/BusEvent.scala
src/main/scala/gr/grnet/aquarium/service/event/StoreIsAliveBusEvent.scala [new file with mode: 0644]
src/main/scala/gr/grnet/aquarium/service/event/StoreIsDeadBusEvent.scala [new file with mode: 0644]
src/main/scala/gr/grnet/aquarium/util/Tags.scala [new file with mode: 0644]
src/main/scala/gr/grnet/aquarium/util/package.scala
src/test/resources/aquarium.properties