Statistics
| Branch: | Tag: | Revision:

root / src / main / scala / gr / grnet / aquarium / connector / rabbitmq @ 07322062

Name Size
  conf
  eventbus
  service
RabbitMQConsumer.scala 11.8 kB

Latest revisions

# Date Author Comment
07322062 05/21/2012 06:18 pm Christos KK Loverdos

Conditionally save events to events store folder

5275697a 05/21/2012 04:56 pm Christos KK Loverdos

Change result type of the json parser used in payload handler

The parser shoulb be as simple as possible. Others will catch errors.

102c12a0 05/21/2012 04:29 pm Christos KK Loverdos

Log errors during the payload handling sequence

e97f6bd5 05/21/2012 04:29 pm Christos KK Loverdos

Change => Unit to => Any in payload handler api

2ae4fe7f 05/21/2012 12:53 pm Christos KK Loverdos

Refine event payload handling

4eed4cdf 05/18/2012 04:29 pm Christos KK Loverdos

Small doc fix

e22e76f7 05/18/2012 04:25 pm Christos KK Loverdos

Fix compilation

That's what happens if one develops and runs the thing from inside an
IDE for while...

11da1c2a 05/18/2012 04:16 pm Christos KK Loverdos

Fix small doc typo

5c7b551b 05/18/2012 02:43 pm Christos KK Loverdos

Add a FIXME for later

6a8f1284 05/18/2012 02:30 pm Christos KK Loverdos

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....

View revisions

Also available in: Atom