Christos KK Loverdos [Fri, 25 May 2012 14:08:16 +0000 (17:08 +0300)]
More complete handling of IM events
Christos KK Loverdos [Fri, 25 May 2012 11:57:58 +0000 (14:57 +0300)]
Expose some debugging facilities in Aquarium class
Christos KK Loverdos [Fri, 25 May 2012 10:26:16 +0000 (13:26 +0300)]
Fix compilation error due to API change in rabbitmq client lib
Christos KK Loverdos [Fri, 25 May 2012 10:16:48 +0000 (13:16 +0300)]
Further optimization of the dependencies
Christos KK Loverdos [Fri, 25 May 2012 10:12:23 +0000 (13:12 +0300)]
Use rabbitmq client lib that matches rabbitmq server version
Christos KK Loverdos [Fri, 25 May 2012 10:10:59 +0000 (13:10 +0300)]
Remove dependency on akka-amqp
Christos KK Loverdos [Fri, 25 May 2012 10:08:13 +0000 (13:08 +0300)]
Keep LRU from guava libraries
Christos KK Loverdos [Fri, 25 May 2012 10:00:33 +0000 (13:00 +0300)]
Remove supervisor of user actors
Christos KK Loverdos [Fri, 25 May 2012 09:48:46 +0000 (12:48 +0300)]
Remove shutdown listener when stopping the rabbitmq consumer
Christos KK Loverdos [Fri, 25 May 2012 09:32:55 +0000 (12:32 +0300)]
Set rabbitmq heartbeat
Christos KK Loverdos [Thu, 24 May 2012 14:13:31 +0000 (17:13 +0300)]
Do not recheck stuff that should have been checked elsewhere
Christos KK Loverdos [Thu, 24 May 2012 14:11:24 +0000 (17:11 +0300)]
Fix requirements for role history item
Christos KK Loverdos [Thu, 24 May 2012 14:10:46 +0000 (17:10 +0300)]
Override debugging info
Christos KK Loverdos [Thu, 24 May 2012 14:09:45 +0000 (17:09 +0300)]
Add one more field to IMEventStateSnapshot
Not sure yet if this will survive.
Christos KK Loverdos [Thu, 24 May 2012 13:10:50 +0000 (16:10 +0300)]
Document the constructor parameters
Christos KK Loverdos [Thu, 24 May 2012 12:58:26 +0000 (15:58 +0300)]
Reorganize startup configuration logging
Christos KK Loverdos [Thu, 24 May 2012 12:50:00 +0000 (15:50 +0300)]
Use acceptMessage as a symmetric response to rejectMessage
Christos KK Loverdos [Thu, 24 May 2012 12:48:57 +0000 (15:48 +0300)]
Add a debugging aid in API of external event model
Christos KK Loverdos [Thu, 24 May 2012 12:22:27 +0000 (15:22 +0300)]
New logic on what to do with incoming im event
Christos KK Loverdos [Thu, 24 May 2012 12:21:36 +0000 (15:21 +0300)]
Add API to IMEventStore
Christos KK Loverdos [Thu, 24 May 2012 10:44:31 +0000 (13:44 +0300)]
Enhance IMStateSnapshot
Christos KK Loverdos [Thu, 24 May 2012 10:43:54 +0000 (13:43 +0300)]
Payload handler post notifier made into a class
Christos KK Loverdos [Thu, 24 May 2012 10:43:21 +0000 (13:43 +0300)]
Payload handlers made into classes
Christos KK Loverdos [Thu, 24 May 2012 10:37:55 +0000 (13:37 +0300)]
Rename agreement snapshot stuff. Agreement history utilities
Christos KK Loverdos [Wed, 23 May 2012 12:56:55 +0000 (15:56 +0300)]
Use factory method
Signed-off-by: Christos KK Loverdos <loverdos@gmail.com>
Christos KK Loverdos [Wed, 23 May 2012 12:37:35 +0000 (15:37 +0300)]
Start forwarding events to user actor
Signed-off-by: Christos KK Loverdos <loverdos@gmail.com>
Christos KK Loverdos [Wed, 23 May 2012 11:18:05 +0000 (14:18 +0300)]
Caught a typo
Signed-off-by: Christos KK Loverdos <loverdos@gmail.com>
Christos KK Loverdos [Wed, 23 May 2012 11:12:55 +0000 (14:12 +0300)]
The bus service uses an executor instead of actors
Christos KK Loverdos [Wed, 23 May 2012 10:13:48 +0000 (13:13 +0300)]
Categorize store folders based on date
Christos KK Loverdos [Tue, 22 May 2012 15:16:00 +0000 (18:16 +0300)]
Ignore logs/
Signed-off-by: Christos KK Loverdos <loverdos@gmail.com>
Christos KK Loverdos [Mon, 21 May 2012 15:18:43 +0000 (18:18 +0300)]
Conditionally save events to events store folder
Christos KK Loverdos [Mon, 21 May 2012 13:56:23 +0000 (16:56 +0300)]
Change result type of the json parser used in payload handler
The parser shoulb be as simple as possible. Others will catch errors.
Christos KK Loverdos [Mon, 21 May 2012 13:29:50 +0000 (16:29 +0300)]
Log errors during the payload handling sequence
Christos KK Loverdos [Mon, 21 May 2012 13:29:10 +0000 (16:29 +0300)]
Change => Unit to => Any in payload handler api
Christos KK Loverdos [Mon, 21 May 2012 13:27:43 +0000 (16:27 +0300)]
Add one more conversion and refactor others
Christos KK Loverdos [Mon, 21 May 2012 10:09:18 +0000 (13:09 +0300)]
Simplify MongoDBStoreProvider state
Christos KK Loverdos [Mon, 21 May 2012 09:58:30 +0000 (12:58 +0300)]
Remove redundant safeUnit() calls
Christos KK Loverdos [Mon, 21 May 2012 09:53:32 +0000 (12:53 +0300)]
Refine event payload handling
Christos KK Loverdos [Fri, 18 May 2012 13:29:20 +0000 (16:29 +0300)]
Small doc fix
Christos KK Loverdos [Fri, 18 May 2012 13:25:23 +0000 (16:25 +0300)]
Fix compilation
That's what happens if one develops and runs the thing from inside an
IDE for while...
Christos KK Loverdos [Fri, 18 May 2012 13:17:40 +0000 (16:17 +0300)]
Read store ping period from configuration (anystore.reconnect.period.millis)
Christos KK Loverdos [Fri, 18 May 2012 13:16:14 +0000 (16:16 +0300)]
Fix small doc typo
Christos KK Loverdos [Fri, 18 May 2012 13:15:05 +0000 (16:15 +0300)]
Force VM exit if Aquarium cannot startup properly
Christos KK Loverdos [Fri, 18 May 2012 11:43:10 +0000 (14:43 +0300)]
Add a FIXME for later
Christos KK Loverdos [Fri, 18 May 2012 11:30:47 +0000 (14:30 +0300)]
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.
Christos KK Loverdos [Fri, 18 May 2012 09:50:49 +0000 (12:50 +0300)]
Pad logger name to right when logging
Christos KK Loverdos [Thu, 17 May 2012 20:36:35 +0000 (23:36 +0300)]
Enhance logging helpers
Christos KK Loverdos [Thu, 17 May 2012 20:32:22 +0000 (23:32 +0300)]
Refactor aquarium startup sequence
Christos KK Loverdos [Thu, 17 May 2012 20:29:17 +0000 (23:29 +0300)]
Cancel timer on stop()
Christos KK Loverdos [Thu, 17 May 2012 13:18:54 +0000 (16:18 +0300)]
Add ping functionality to two of the stores
Christos KK Loverdos [Thu, 17 May 2012 11:41:27 +0000 (14:41 +0300)]
Make Aquarium a service. Move startup functionality to it.
Christos KK Loverdos [Wed, 16 May 2012 12:23:30 +0000 (15:23 +0300)]
Rename Configurator to Aquarium
Christos KK Loverdos [Wed, 16 May 2012 11:46:07 +0000 (14:46 +0300)]
Improved error reporting if failed to start
Christos KK Loverdos [Wed, 16 May 2012 11:31:17 +0000 (14:31 +0300)]
WIP Rework AMQP stuff: Automatic reconnection to RabbitMQ
Christos KK Loverdos [Wed, 16 May 2012 11:17:54 +0000 (14:17 +0300)]
Set aquarium.properties on default case (home=.)
Christos KK Loverdos [Wed, 16 May 2012 11:16:33 +0000 (14:16 +0300)]
Ignore yet another dummy folder created by logback
Christos KK Loverdos [Wed, 16 May 2012 11:05:01 +0000 (14:05 +0300)]
Ignore dummy folder created by logback
Christos KK Loverdos [Wed, 16 May 2012 11:03:26 +0000 (14:03 +0300)]
Obtain Aquarium Home in a cleaner and more flexible way
Christos KK Loverdos [Wed, 16 May 2012 09:27:43 +0000 (12:27 +0300)]
Restructure configuration resources (code & data)
Christos KK Loverdos [Tue, 15 May 2012 12:45:21 +0000 (15:45 +0300)]
Change logStoppingF -> logStartingF
Christos KK Loverdos [Tue, 15 May 2012 12:22:25 +0000 (15:22 +0300)]
Small fix to make it compile
Christos KK Loverdos [Mon, 14 May 2012 21:33:34 +0000 (00:33 +0300)]
Logging facilities
Christos KK Loverdos [Mon, 14 May 2012 15:37:38 +0000 (18:37 +0300)]
WIP Rework AMQP stuff: Working on reconnect
Christos KK Loverdos [Mon, 14 May 2012 15:11:36 +0000 (18:11 +0300)]
WIP Rework AMQP stuff: Aquarium starts OK even if queue is down
Christos KK Loverdos [Mon, 14 May 2012 14:37:27 +0000 (17:37 +0300)]
WIP Rework AMQP stuff
Christos KK Loverdos [Mon, 14 May 2012 08:49:44 +0000 (11:49 +0300)]
WIP Rework AMQP stuff
Christos KK Loverdos [Fri, 11 May 2012 15:46:14 +0000 (18:46 +0300)]
WIP Rework AMQP stuff
Christos KK Loverdos [Fri, 11 May 2012 15:23:02 +0000 (18:23 +0300)]
WIP Rework AMQP stuff
Channel QOS stuff
Christos KK Loverdos [Fri, 11 May 2012 14:44:53 +0000 (17:44 +0300)]
WIP Reowrk AMQP stuff and introduce the event bus
Christos KK Loverdos [Fri, 11 May 2012 08:10:33 +0000 (11:10 +0300)]
Upgrade google guava libraries
Christos KK Loverdos [Thu, 10 May 2012 15:25:51 +0000 (18:25 +0300)]
WIP Reowrk AMQP stuff
Christos KK Loverdos [Thu, 10 May 2012 15:25:19 +0000 (18:25 +0300)]
Add some dangerous reflection helpers
Christos KK Loverdos [Thu, 10 May 2012 12:09:34 +0000 (15:09 +0300)]
WIP Reowrk AMQP stuff.
Reasons (in no particular order):
1. Started getting some exception from akka-amqp module out of the
blue.
2. akka-amqp module, used by the current implementation, is not going to
be supported anymore and I cannot depend on such random decisions.
3. It is better to debug your own software than the others'.
4. Current approach (akka-amqp + aquarium implementation) has some semantic
holes and shortcomings with regard to supervision, internal error handling,
connection failure handling and message processing order.
Christos KK Loverdos [Thu, 10 May 2012 11:30:00 +0000 (14:30 +0300)]
Introduce local configuration
Christos KK Loverdos [Thu, 10 May 2012 11:00:04 +0000 (14:00 +0300)]
Remove unused property
Christos KK Loverdos [Thu, 10 May 2012 10:15:29 +0000 (13:15 +0300)]
Event refactoring
Christos KK Loverdos [Wed, 9 May 2012 13:47:22 +0000 (16:47 +0300)]
Tweeking configuration
Use classpath for logback.xml, (re?)introduce akka.conf.
Christos KK Loverdos [Wed, 9 May 2012 10:17:21 +0000 (13:17 +0300)]
Echo changes
Christos KK Loverdos [Wed, 9 May 2012 09:30:13 +0000 (12:30 +0300)]
Use PID_FILE
Christos KK Loverdos [Wed, 9 May 2012 09:26:59 +0000 (12:26 +0300)]
Add forcekill script option
Christos KK Loverdos [Mon, 7 May 2012 15:21:58 +0000 (18:21 +0300)]
Refactor charging computation + data
Christos KK Loverdos [Mon, 7 May 2012 12:34:56 +0000 (15:34 +0300)]
Make class final
Christos KK Loverdos [Mon, 7 May 2012 12:20:37 +0000 (15:20 +0300)]
WIP: ResourceEvent-related refactorings
Christos KK Loverdos [Mon, 7 May 2012 11:37:16 +0000 (14:37 +0300)]
Change API for contextual logger usage
Christos KK Loverdos [Mon, 7 May 2012 11:04:31 +0000 (14:04 +0300)]
Discover if running junit tests
Christos KK Loverdos [Mon, 7 May 2012 11:03:26 +0000 (14:03 +0300)]
One more use of AquariumInternalError
Christos KK Loverdos [Mon, 7 May 2012 11:02:46 +0000 (14:02 +0300)]
Rename logback test configuration
Christos KK Loverdos [Mon, 7 May 2012 10:47:22 +0000 (13:47 +0300)]
Simplify startup with one parameter less
Christos KK Loverdos [Mon, 7 May 2012 10:10:25 +0000 (13:10 +0300)]
Use newest Maybe API
Christos KK Loverdos [Mon, 7 May 2012 10:00:14 +0000 (13:00 +0300)]
Use file.encoding from library
Christos KK Loverdos [Sat, 5 May 2012 19:39:29 +0000 (22:39 +0300)]
Use AquariumInternalError
Christos KK Loverdos [Fri, 4 May 2012 14:42:06 +0000 (17:42 +0300)]
Add ps command to aquarium script
Christos KK Loverdos [Fri, 4 May 2012 14:09:03 +0000 (17:09 +0300)]
Add helper script for locally running setup
Christos KK Loverdos [Fri, 4 May 2012 12:16:27 +0000 (15:16 +0300)]
Remove unused file
Christos KK Loverdos [Thu, 3 May 2012 14:39:23 +0000 (17:39 +0300)]
Refactor actor messages
Christos KK Loverdos [Thu, 3 May 2012 13:12:00 +0000 (16:12 +0300)]
Make the parameterized actor constructor private
Christos KK Loverdos [Thu, 3 May 2012 12:57:45 +0000 (15:57 +0300)]
WIP: IMEventModel end-to-end chain
Keeping IMState locally in the UserActor.
Christos KK Loverdos [Thu, 3 May 2012 10:31:36 +0000 (13:31 +0300)]
Aquarium internal error
Christos KK Loverdos [Thu, 3 May 2012 10:22:56 +0000 (13:22 +0300)]
WIP: IMEventModel end-to-end chain
Christos KK Loverdos [Thu, 3 May 2012 09:21:54 +0000 (12:21 +0300)]
Use stop() instead of PoisonPill