aquarium
12 years agoConditionally save events to events store folder
Christos KK Loverdos [Mon, 21 May 2012 15:18:43 +0000 (18:18 +0300)]
Conditionally save events to events store folder

12 years agoChange result type of the json parser used in payload handler
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.

12 years agoLog errors during the payload handling sequence
Christos KK Loverdos [Mon, 21 May 2012 13:29:50 +0000 (16:29 +0300)]
Log errors during the payload handling sequence

12 years agoChange => Unit to => Any in payload handler api
Christos KK Loverdos [Mon, 21 May 2012 13:29:10 +0000 (16:29 +0300)]
Change => Unit to => Any in payload handler api

12 years agoAdd one more conversion and refactor others
Christos KK Loverdos [Mon, 21 May 2012 13:27:43 +0000 (16:27 +0300)]
Add one more conversion and refactor others

12 years agoSimplify MongoDBStoreProvider state
Christos KK Loverdos [Mon, 21 May 2012 10:09:18 +0000 (13:09 +0300)]
Simplify MongoDBStoreProvider state

12 years agoRemove redundant safeUnit() calls
Christos KK Loverdos [Mon, 21 May 2012 09:58:30 +0000 (12:58 +0300)]
Remove redundant safeUnit() calls

12 years agoRefine event payload handling
Christos KK Loverdos [Mon, 21 May 2012 09:53:32 +0000 (12:53 +0300)]
Refine event payload handling

12 years agoSmall doc fix
Christos KK Loverdos [Fri, 18 May 2012 13:29:20 +0000 (16:29 +0300)]
Small doc fix

12 years agoFix compilation
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...

12 years agoRead store ping period from configuration (anystore.reconnect.period.millis)
Christos KK Loverdos [Fri, 18 May 2012 13:17:40 +0000 (16:17 +0300)]
Read store ping period from configuration (anystore.reconnect.period.millis)

12 years agoFix small doc typo
Christos KK Loverdos [Fri, 18 May 2012 13:16:14 +0000 (16:16 +0300)]
Fix small doc typo

12 years agoForce VM exit if Aquarium cannot startup properly
Christos KK Loverdos [Fri, 18 May 2012 13:15:05 +0000 (16:15 +0300)]
Force VM exit if Aquarium cannot startup properly

12 years agoAdd a FIXME for later
Christos KK Loverdos [Fri, 18 May 2012 11:43:10 +0000 (14:43 +0300)]
Add a FIXME for later

12 years agoAMQP stuff is now in good shape
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.

12 years agoPad logger name to right when logging
Christos KK Loverdos [Fri, 18 May 2012 09:50:49 +0000 (12:50 +0300)]
Pad logger name to right when logging

12 years agoEnhance logging helpers
Christos KK Loverdos [Thu, 17 May 2012 20:36:35 +0000 (23:36 +0300)]
Enhance logging helpers

12 years agoRefactor aquarium startup sequence
Christos KK Loverdos [Thu, 17 May 2012 20:32:22 +0000 (23:32 +0300)]
Refactor aquarium startup sequence

12 years agoCancel timer on stop()
Christos KK Loverdos [Thu, 17 May 2012 20:29:17 +0000 (23:29 +0300)]
Cancel timer on stop()

12 years agoAdd ping functionality to two of the stores
Christos KK Loverdos [Thu, 17 May 2012 13:18:54 +0000 (16:18 +0300)]
Add ping functionality to two of the stores

12 years agoMake Aquarium a service. Move startup functionality to it.
Christos KK Loverdos [Thu, 17 May 2012 11:41:27 +0000 (14:41 +0300)]
Make Aquarium a service. Move startup functionality to it.

12 years agoRename Configurator to Aquarium
Christos KK Loverdos [Wed, 16 May 2012 12:23:30 +0000 (15:23 +0300)]
Rename Configurator to Aquarium

12 years agoImproved error reporting if failed to start
Christos KK Loverdos [Wed, 16 May 2012 11:46:07 +0000 (14:46 +0300)]
Improved error reporting if failed to start

12 years agoWIP Rework AMQP stuff: Automatic reconnection to RabbitMQ
Christos KK Loverdos [Wed, 16 May 2012 11:31:17 +0000 (14:31 +0300)]
WIP Rework AMQP stuff: Automatic reconnection to RabbitMQ

12 years agoSet aquarium.properties on default case (home=.)
Christos KK Loverdos [Wed, 16 May 2012 11:17:54 +0000 (14:17 +0300)]
Set aquarium.properties on default case (home=.)

12 years agoIgnore yet another dummy folder created by logback
Christos KK Loverdos [Wed, 16 May 2012 11:16:33 +0000 (14:16 +0300)]
Ignore yet another dummy folder created by logback

12 years agoIgnore 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

12 years agoObtain Aquarium Home in a cleaner and more flexible way
Christos KK Loverdos [Wed, 16 May 2012 11:03:26 +0000 (14:03 +0300)]
Obtain Aquarium Home in a cleaner and more flexible way

12 years agoRestructure configuration resources (code & data)
Christos KK Loverdos [Wed, 16 May 2012 09:27:43 +0000 (12:27 +0300)]
Restructure configuration resources (code & data)

12 years agoChange logStoppingF -> logStartingF
Christos KK Loverdos [Tue, 15 May 2012 12:45:21 +0000 (15:45 +0300)]
Change logStoppingF -> logStartingF

12 years agoSmall fix to make it compile
Christos KK Loverdos [Tue, 15 May 2012 12:22:25 +0000 (15:22 +0300)]
Small fix to make it compile

12 years agoLogging facilities
Christos KK Loverdos [Mon, 14 May 2012 21:33:34 +0000 (00:33 +0300)]
Logging facilities

12 years agoWIP Rework AMQP stuff: Working on reconnect
Christos KK Loverdos [Mon, 14 May 2012 15:37:38 +0000 (18:37 +0300)]
WIP Rework AMQP stuff: Working on reconnect

12 years agoWIP Rework AMQP stuff: Aquarium starts OK even if queue is down
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

12 years agoWIP Rework AMQP stuff
Christos KK Loverdos [Mon, 14 May 2012 14:37:27 +0000 (17:37 +0300)]
WIP Rework AMQP stuff

12 years agoWIP Rework AMQP stuff
Christos KK Loverdos [Mon, 14 May 2012 08:49:44 +0000 (11:49 +0300)]
WIP Rework AMQP stuff

12 years agoWIP Rework AMQP stuff
Christos KK Loverdos [Fri, 11 May 2012 15:46:14 +0000 (18:46 +0300)]
WIP Rework AMQP stuff

12 years agoWIP Rework AMQP stuff
Christos KK Loverdos [Fri, 11 May 2012 15:23:02 +0000 (18:23 +0300)]
WIP Rework AMQP stuff

Channel QOS stuff

12 years agoWIP Reowrk AMQP stuff and introduce the event bus
Christos KK Loverdos [Fri, 11 May 2012 14:44:53 +0000 (17:44 +0300)]
WIP Reowrk AMQP stuff and introduce the event bus

12 years agoUpgrade google guava libraries
Christos KK Loverdos [Fri, 11 May 2012 08:10:33 +0000 (11:10 +0300)]
Upgrade google guava libraries

12 years agoWIP Reowrk AMQP stuff
Christos KK Loverdos [Thu, 10 May 2012 15:25:51 +0000 (18:25 +0300)]
WIP Reowrk AMQP stuff

12 years agoAdd some dangerous reflection helpers
Christos KK Loverdos [Thu, 10 May 2012 15:25:19 +0000 (18:25 +0300)]
Add some dangerous reflection helpers

12 years agoWIP Reowrk AMQP stuff.
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.

12 years agoIntroduce local configuration
Christos KK Loverdos [Thu, 10 May 2012 11:30:00 +0000 (14:30 +0300)]
Introduce local configuration

12 years agoRemove unused property
Christos KK Loverdos [Thu, 10 May 2012 11:00:04 +0000 (14:00 +0300)]
Remove unused property

12 years agoEvent refactoring
Christos KK Loverdos [Thu, 10 May 2012 10:15:29 +0000 (13:15 +0300)]
Event refactoring

12 years agoTweeking configuration
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.

12 years agoEcho changes
Christos KK Loverdos [Wed, 9 May 2012 10:17:21 +0000 (13:17 +0300)]
Echo changes

12 years agoUse PID_FILE
Christos KK Loverdos [Wed, 9 May 2012 09:30:13 +0000 (12:30 +0300)]
Use PID_FILE

12 years agoAdd forcekill script option
Christos KK Loverdos [Wed, 9 May 2012 09:26:59 +0000 (12:26 +0300)]
Add forcekill script option

12 years agoRefactor charging computation + data
Christos KK Loverdos [Mon, 7 May 2012 15:21:58 +0000 (18:21 +0300)]
Refactor charging computation + data

12 years agoMake class final
Christos KK Loverdos [Mon, 7 May 2012 12:34:56 +0000 (15:34 +0300)]
Make class final

12 years agoWIP: ResourceEvent-related refactorings
Christos KK Loverdos [Mon, 7 May 2012 12:20:37 +0000 (15:20 +0300)]
WIP: ResourceEvent-related refactorings

12 years agoChange API for contextual logger usage
Christos KK Loverdos [Mon, 7 May 2012 11:37:16 +0000 (14:37 +0300)]
Change API for contextual logger usage

12 years agoDiscover if running junit tests
Christos KK Loverdos [Mon, 7 May 2012 11:04:31 +0000 (14:04 +0300)]
Discover if running junit tests

12 years agoOne more use of AquariumInternalError
Christos KK Loverdos [Mon, 7 May 2012 11:03:26 +0000 (14:03 +0300)]
One more use of AquariumInternalError

12 years agoRename logback test configuration
Christos KK Loverdos [Mon, 7 May 2012 11:02:46 +0000 (14:02 +0300)]
Rename logback test configuration

12 years agoSimplify startup with one parameter less
Christos KK Loverdos [Mon, 7 May 2012 10:47:22 +0000 (13:47 +0300)]
Simplify startup with one parameter less

12 years agoUse newest Maybe API
Christos KK Loverdos [Mon, 7 May 2012 10:10:25 +0000 (13:10 +0300)]
Use newest Maybe API

12 years agoUse file.encoding from library
Christos KK Loverdos [Mon, 7 May 2012 10:00:14 +0000 (13:00 +0300)]
Use file.encoding from library

12 years agoUse AquariumInternalError
Christos KK Loverdos [Sat, 5 May 2012 19:39:29 +0000 (22:39 +0300)]
Use AquariumInternalError

12 years agoAdd ps command to aquarium script
Christos KK Loverdos [Fri, 4 May 2012 14:42:06 +0000 (17:42 +0300)]
Add ps command to aquarium script

12 years agoAdd helper script for locally running setup
Christos KK Loverdos [Fri, 4 May 2012 14:09:03 +0000 (17:09 +0300)]
Add helper script for locally running setup

12 years agoRemove unused file
Christos KK Loverdos [Fri, 4 May 2012 12:16:27 +0000 (15:16 +0300)]
Remove unused file

12 years agoRefactor actor messages
Christos KK Loverdos [Thu, 3 May 2012 14:39:23 +0000 (17:39 +0300)]
Refactor actor messages

12 years agoMake the parameterized actor constructor private
Christos KK Loverdos [Thu, 3 May 2012 13:12:00 +0000 (16:12 +0300)]
Make the parameterized actor constructor private

12 years agoWIP: IMEventModel end-to-end chain
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.

12 years agoAquarium internal error
Christos KK Loverdos [Thu, 3 May 2012 10:31:36 +0000 (13:31 +0300)]
Aquarium internal error

12 years agoWIP: IMEventModel end-to-end chain
Christos KK Loverdos [Thu, 3 May 2012 10:22:56 +0000 (13:22 +0300)]
WIP: IMEventModel end-to-end chain

12 years agoUse stop() instead of PoisonPill
Christos KK Loverdos [Thu, 3 May 2012 09:21:54 +0000 (12:21 +0300)]
Use stop() instead of PoisonPill

12 years agoParametrerized trace index for logging chain of causes
Christos KK Loverdos [Thu, 3 May 2012 08:38:12 +0000 (11:38 +0300)]
Parametrerized trace index for logging chain of causes

12 years agoLogging enhancements
Christos KK Loverdos [Fri, 27 Apr 2012 14:07:54 +0000 (17:07 +0300)]
Logging enhancements

12 years agoPersister is now reflective
Christos KK Loverdos [Fri, 27 Apr 2012 13:38:16 +0000 (16:38 +0300)]
Persister is now reflective

It seems I have better controls on what is going on right now.
The overall architecture of persisting still needs reviewing though.

12 years agoRemove unused code
Christos KK Loverdos [Fri, 27 Apr 2012 13:36:56 +0000 (16:36 +0300)]
Remove unused code

12 years agoReflective actor uses simple class names to decide on the methods
Christos KK Loverdos [Fri, 27 Apr 2012 13:35:23 +0000 (16:35 +0300)]
Reflective actor uses simple class names to decide on the methods

12 years agoLogging enhancements
Christos KK Loverdos [Fri, 27 Apr 2012 13:20:56 +0000 (16:20 +0300)]
Logging enhancements

12 years agoFix stack overflow exception
Christos KK Loverdos [Fri, 27 Apr 2012 11:51:34 +0000 (14:51 +0300)]
Fix stack overflow exception

12 years agoString and class-name utilities
Christos KK Loverdos [Fri, 27 Apr 2012 11:38:50 +0000 (14:38 +0300)]
String and class-name utilities

12 years agoEnhance [Lazy]Loggable
Christos KK Loverdos [Fri, 27 Apr 2012 11:28:01 +0000 (14:28 +0300)]
Enhance [Lazy]Loggable

12 years agoReflective actor is a bit more decoupled now
Christos KK Loverdos [Fri, 27 Apr 2012 11:16:35 +0000 (14:16 +0300)]
Reflective actor is a bit more decoupled now

12 years agoWIP: IMEventModel end-to-end chain
Christos KK Loverdos [Fri, 27 Apr 2012 11:03:05 +0000 (14:03 +0300)]
WIP: IMEventModel end-to-end chain

12 years agoUsing isDefined, since we no longer have a maybe
Christos KK Loverdos [Fri, 27 Apr 2012 10:58:59 +0000 (13:58 +0300)]
Using isDefined, since we no longer have a maybe

12 years agoRemodeling events
Christos KK Loverdos [Thu, 26 Apr 2012 14:43:36 +0000 (17:43 +0300)]
Remodeling events

12 years agoInclude servicing message in exception handling
Christos KK Loverdos [Thu, 26 Apr 2012 10:19:03 +0000 (13:19 +0300)]
Include servicing message in exception handling

12 years agoOoops... Multistatement bug?
Christos KK Loverdos [Wed, 25 Apr 2012 14:40:08 +0000 (17:40 +0300)]
Ooops... Multistatement bug?

12 years agoReflective actor handles exceptions in an extensible way
Christos KK Loverdos [Wed, 25 Apr 2012 14:36:56 +0000 (17:36 +0300)]
Reflective actor handles exceptions in an extensible way

12 years agoWIP: Remodeling UserState store mechanics
Christos KK Loverdos [Wed, 25 Apr 2012 14:05:07 +0000 (17:05 +0300)]
WIP: Remodeling UserState store mechanics

12 years agoDelete unused IMEvent (old model)
Christos KK Loverdos [Wed, 25 Apr 2012 13:30:43 +0000 (16:30 +0300)]
Delete unused IMEvent (old model)

12 years agoAdd resource-handling utility method
Christos KK Loverdos [Wed, 25 Apr 2012 13:27:35 +0000 (16:27 +0300)]
Add resource-handling utility method

12 years agoWIP: Reshaping UserActor
Christos KK Loverdos [Wed, 25 Apr 2012 12:18:10 +0000 (15:18 +0300)]
WIP: Reshaping UserActor

12 years agoAdd rabbitmq helper script (for running locally)
Christos KK Loverdos [Wed, 25 Apr 2012 12:06:57 +0000 (15:06 +0300)]
Add rabbitmq helper script (for running locally)

12 years agoRework message routing
Christos KK Loverdos [Wed, 25 Apr 2012 12:02:58 +0000 (15:02 +0300)]
Rework message routing

12 years agoFix compilation
Christos KK Loverdos [Wed, 25 Apr 2012 10:59:22 +0000 (13:59 +0300)]
Fix compilation

12 years agoExceptions are raised anyway given the JOURNAL_SAFE write level
Christos KK Loverdos [Wed, 25 Apr 2012 10:13:34 +0000 (13:13 +0300)]
Exceptions are raised anyway given the JOURNAL_SAFE write level

12 years agoRemove unused code
Christos KK Loverdos [Wed, 25 Apr 2012 09:14:18 +0000 (12:14 +0300)]
Remove unused code

12 years agoShaving off UserActorManager. Router does the work
Christos KK Loverdos [Wed, 25 Apr 2012 05:40:35 +0000 (08:40 +0300)]
Shaving off UserActorManager. Router does the work

12 years agoDispatcher -> Router (II)
Christos KK Loverdos [Wed, 25 Apr 2012 05:35:17 +0000 (08:35 +0300)]
Dispatcher -> Router (II)

12 years agoDispatcher -> Router
Christos KK Loverdos [Wed, 25 Apr 2012 05:26:15 +0000 (08:26 +0300)]
Dispatcher -> Router

12 years agoRemove code
Christos KK Loverdos [Tue, 24 Apr 2012 12:46:39 +0000 (15:46 +0300)]
Remove code

12 years agoWIP: IMEventModel end-to-end chain
Christos KK Loverdos [Tue, 24 Apr 2012 11:39:16 +0000 (14:39 +0300)]
WIP: IMEventModel end-to-end chain