Christos KK Loverdos [Mon, 19 Dec 2011 16:26:32 +0000 (18:26 +0200)]
Work in progres towards handling UserRequestGetBalance end-to-end.
Christos KK Loverdos [Mon, 19 Dec 2011 15:48:30 +0000 (17:48 +0200)]
Remove unused dependency.
Christos KK Loverdos [Mon, 19 Dec 2011 15:44:49 +0000 (17:44 +0200)]
Fix version in akka component.
Georgios Gousios [Mon, 19 Dec 2011 15:51:59 +0000 (17:51 +0200)]
Generate random users and user events
Georgios Gousios [Mon, 19 Dec 2011 15:51:27 +0000 (17:51 +0200)]
User state event, coming from IM (astakos)
Georgios Gousios [Mon, 19 Dec 2011 15:49:53 +0000 (17:49 +0200)]
Formatting fixes
Georgios Gousios [Mon, 19 Dec 2011 15:48:56 +0000 (17:48 +0200)]
Empty implementation of the IM event store
Georgios Gousios [Fri, 16 Dec 2011 14:17:09 +0000 (16:17 +0200)]
Handle unlimited redeliveries of failed messages
Georgios Gousios [Fri, 16 Dec 2011 12:06:10 +0000 (14:06 +0200)]
Better logging, better stopping of actors
Georgios Gousios [Fri, 16 Dec 2011 12:03:43 +0000 (14:03 +0200)]
Don't share the same connection for all consumers + producers
Christos KK Loverdos [Fri, 16 Dec 2011 11:38:15 +0000 (13:38 +0200)]
Remove unused MongoDB configuration.
Do I get the master-shaver prize, yet?
Christos KK Loverdos [Fri, 16 Dec 2011 11:36:06 +0000 (13:36 +0200)]
Implement MondoDB-based UserStore with basic queries.
Georgios Gousios [Fri, 16 Dec 2011 10:36:46 +0000 (12:36 +0200)]
Pools and loadbalancing for resource event actors
Christos KK Loverdos [Fri, 16 Dec 2011 10:21:28 +0000 (12:21 +0200)]
Ditch RESTService since it only had Lifecycle.
Christos KK Loverdos [Fri, 16 Dec 2011 09:50:26 +0000 (11:50 +0200)]
Another shaving round.
Christos KK Loverdos [Fri, 16 Dec 2011 09:21:33 +0000 (11:21 +0200)]
Big shaving. No foam.
Georgios Gousios [Thu, 15 Dec 2011 16:30:38 +0000 (18:30 +0200)]
Fix various bugs
-use var instead of val in rnd loop to avoid posting the same message
-Return the failure in case mongo cannot store a result
Georgios Gousios [Thu, 15 Dec 2011 15:58:10 +0000 (17:58 +0200)]
Use the stored actor ref, don't create a new one
Georgios Gousios [Thu, 15 Dec 2011 15:20:44 +0000 (17:20 +0200)]
A bit of logging never hurts
Georgios Gousios [Thu, 15 Dec 2011 15:20:28 +0000 (17:20 +0200)]
Don't run spray tests by default
Georgios Gousios [Thu, 15 Dec 2011 15:20:15 +0000 (17:20 +0200)]
Initialize the system lazily
Georgios Gousios [Thu, 15 Dec 2011 15:19:39 +0000 (17:19 +0200)]
Method to run the random event generator
Georgios Gousios [Thu, 15 Dec 2011 15:17:08 +0000 (17:17 +0200)]
Move RandomEventGenerator to main source tree
Georgios Gousios [Thu, 15 Dec 2011 14:41:20 +0000 (16:41 +0200)]
Support for starting the event reader as a service
Christos KK Loverdos [Thu, 15 Dec 2011 14:37:56 +0000 (16:37 +0200)]
Small fix to properties files, just for the sake of a better reference point
Christos KK Loverdos [Thu, 15 Dec 2011 14:15:17 +0000 (16:15 +0200)]
More user-friendly error handling when dynamically creating and configuring instances.
Georgios Gousios [Thu, 15 Dec 2011 14:01:29 +0000 (16:01 +0200)]
Build an aquarium jar with dependencies
Georgios Gousios [Thu, 15 Dec 2011 13:47:53 +0000 (15:47 +0200)]
Temp fix for a potential bug
Christos KK Loverdos [Thu, 15 Dec 2011 13:03:12 +0000 (15:03 +0200)]
Fix regression that caused an infinite loop in service initialization
Georgios Gousios [Thu, 15 Dec 2011 13:02:29 +0000 (15:02 +0200)]
Fixes to make it compile with the current version of the API
Georgios Gousios [Thu, 15 Dec 2011 12:31:17 +0000 (14:31 +0200)]
Attempt to create a main class
Georgios Gousios [Thu, 15 Dec 2011 12:31:01 +0000 (14:31 +0200)]
Convert to getting the various stores from Masterconf
Christos KK Loverdos [Thu, 15 Dec 2011 12:34:04 +0000 (14:34 +0200)]
Unify store provisioning.
Georgios Gousios [Thu, 15 Dec 2011 11:59:23 +0000 (13:59 +0200)]
Add implementation class
Christos KK Loverdos [Thu, 15 Dec 2011 11:51:51 +0000 (13:51 +0200)]
Add lifecycle abstraction for use by several services.
Christos KK Loverdos [Thu, 15 Dec 2011 11:48:38 +0000 (13:48 +0200)]
Small fix for uncommited code dependency.
Christos KK Loverdos [Thu, 15 Dec 2011 11:46:26 +0000 (13:46 +0200)]
Wire-up the (mongodb-based for now) event store to the configurator.
Georgios Gousios [Wed, 14 Dec 2011 15:36:08 +0000 (17:36 +0200)]
Revert to Java MongoDB driver, impl remaining methods
Also clean up mongo after test
Georgios Gousios [Wed, 14 Dec 2011 13:12:19 +0000 (15:12 +0200)]
Commit for posterity
Will revert to plain Java driver for now
Christos KK Loverdos [Wed, 14 Dec 2011 10:50:13 +0000 (12:50 +0200)]
Upgrade akka to 1.3-RC4.
Christos KK Loverdos [Tue, 13 Dec 2011 14:02:15 +0000 (16:02 +0200)]
Implement a memory-based UserStore and hook it in the properties.
Christos KK Loverdos [Tue, 13 Dec 2011 12:23:11 +0000 (14:23 +0200)]
Factor out some common Json (+ Xml) functionality.
Georgios Gousios [Tue, 13 Dec 2011 11:47:51 +0000 (13:47 +0200)]
Tests for the eventstore functionality
Georgios Gousios [Tue, 13 Dec 2011 11:47:21 +0000 (13:47 +0200)]
Fix naming clashes with other traits
Georgios Gousios [Tue, 13 Dec 2011 11:46:12 +0000 (13:46 +0200)]
A port is always an integer, not a string :-)
Christos KK Loverdos [Tue, 13 Dec 2011 11:04:35 +0000 (13:04 +0200)]
Upgrade Akka to 1.3-RC3.
Anxiously waiting for 1.3.final and 2.0.
Christos KK Loverdos [Tue, 13 Dec 2011 11:03:00 +0000 (13:03 +0200)]
Start modeling the User store.
Christos KK Loverdos [Tue, 13 Dec 2011 10:59:01 +0000 (12:59 +0200)]
Explicitly include parent class fields in serialization.
Christos KK Loverdos [Tue, 13 Dec 2011 10:53:02 +0000 (12:53 +0200)]
Ignore fs-local properties.
Christos KK Loverdos [Tue, 13 Dec 2011 10:50:21 +0000 (12:50 +0200)]
Bogus enhancements
Christos KK Loverdos [Tue, 13 Dec 2011 10:16:30 +0000 (12:16 +0200)]
Fix inheritance bug (did not compile).
Christos KK Loverdos [Tue, 13 Dec 2011 10:04:04 +0000 (12:04 +0200)]
Start describing the User state. Modeling it as snapshots.
Christos KK Loverdos [Mon, 12 Dec 2011 15:27:54 +0000 (17:27 +0200)]
Code cleanup.
Christos KK Loverdos [Mon, 12 Dec 2011 15:21:13 +0000 (17:21 +0200)]
Start implementing user balance REST request.
Christos KK Loverdos [Mon, 12 Dec 2011 13:21:49 +0000 (15:21 +0200)]
Remove unused actor factories. Now superceded by the actor provider.
Georgios Gousios [Mon, 12 Dec 2011 14:56:02 +0000 (16:56 +0200)]
Use the event store in the event processor to persist resource events
Georgios Gousios [Mon, 12 Dec 2011 14:54:53 +0000 (16:54 +0200)]
Compilation fixes
Georgios Gousios [Mon, 12 Dec 2011 14:54:40 +0000 (16:54 +0200)]
Implementation of the EventStore interface in the Mongo driver
Georgios Gousios [Mon, 12 Dec 2011 14:54:04 +0000 (16:54 +0200)]
Renames to more meaningfull names
Georgios Gousios [Mon, 12 Dec 2011 14:51:46 +0000 (16:51 +0200)]
All Aquarium events have a client defined unique id
Georgios Gousios [Mon, 12 Dec 2011 14:50:56 +0000 (16:50 +0200)]
The persistence database schema as a configurable option
Georgios Gousios [Mon, 12 Dec 2011 11:12:13 +0000 (13:12 +0200)]
Factory for getting MessageStores based on configuration
Georgios Gousios [Mon, 12 Dec 2011 11:11:34 +0000 (13:11 +0200)]
Configure and use Mongo's connection pool
Georgios Gousios [Mon, 12 Dec 2011 11:09:57 +0000 (13:09 +0200)]
Options for connecting to a persistence provider
Christos KK Loverdos [Mon, 12 Dec 2011 11:24:44 +0000 (13:24 +0200)]
Some more service orientation to master conf
Christos KK Loverdos [Mon, 12 Dec 2011 10:17:24 +0000 (12:17 +0200)]
Add a test for RESTActor.
Christos KK Loverdos [Mon, 12 Dec 2011 10:16:17 +0000 (12:16 +0200)]
Add RESTRole (and, hence, RESTActor) to known roles/actors for provisioning.
Christos KK Loverdos [Mon, 12 Dec 2011 10:13:59 +0000 (12:13 +0200)]
Properly (?) quote field name in JSON response for /ping.
At least, this is what is needed for the default bahavior of Lift's json
parser.
Christos KK Loverdos [Mon, 12 Dec 2011 10:13:25 +0000 (12:13 +0200)]
Make default constructor for RESTActor.
Christos KK Loverdos [Mon, 12 Dec 2011 09:15:11 +0000 (11:15 +0200)]
Add rest service port configuration and respective actor role.
Christos KK Loverdos [Mon, 12 Dec 2011 09:07:10 +0000 (11:07 +0200)]
Make props visible to outer world.
We need this to take advantage of all conversion utilities etc. so that
we do not have to replicate the Props API in MasterConf itself.
Christos KK Loverdos [Mon, 12 Dec 2011 09:06:15 +0000 (11:06 +0200)]
Rename package akka and main REST actor.
Georgios Gousios [Mon, 12 Dec 2011 08:49:56 +0000 (10:49 +0200)]
Send an appropriate event key
Georgios Gousios [Mon, 12 Dec 2011 08:48:32 +0000 (10:48 +0200)]
Restrict exchange declarations from clients
Christos KK Loverdos [Fri, 9 Dec 2011 14:51:31 +0000 (16:51 +0200)]
Thought untested, the REST service now sends to Dispatcher.
Christos KK Loverdos [Fri, 9 Dec 2011 14:47:20 +0000 (16:47 +0200)]
Introduce the Dispatcher-related messages, all given in one place.
Georgios Gousios [Fri, 9 Dec 2011 14:22:15 +0000 (16:22 +0200)]
Configuration params for the AMQP queue
Georgios Gousios [Fri, 9 Dec 2011 14:20:48 +0000 (16:20 +0200)]
Support for statically getting config param value
Georgios Gousios [Fri, 9 Dec 2011 13:16:15 +0000 (15:16 +0200)]
Actors for resource event processing
Christos KK Loverdos [Fri, 9 Dec 2011 13:19:15 +0000 (15:19 +0200)]
Add missing ActorProxy, so that tests compile
Christos KK Loverdos [Fri, 9 Dec 2011 11:51:37 +0000 (13:51 +0200)]
Add more tests for MasterConf loading.
Christos KK Loverdos [Fri, 9 Dec 2011 11:41:53 +0000 (13:41 +0200)]
Now loading the default actor provider from properties.
Christos KK Loverdos [Fri, 9 Dec 2011 11:25:02 +0000 (13:25 +0200)]
Move SimpleLocalActorProvider
Christos KK Loverdos [Fri, 9 Dec 2011 11:06:51 +0000 (13:06 +0200)]
Setting the stage for actor provision and wiring. WIP.
Christos KK Loverdos [Fri, 9 Dec 2011 09:58:11 +0000 (11:58 +0200)]
Introduce MasterConf, assuming an aquarium.properties
Also did some reorganization of actor stuff.
Georgios Gousios [Thu, 8 Dec 2011 15:24:20 +0000 (17:24 +0200)]
Correct parameters for producer/consumer construction
Georgios Gousios [Wed, 7 Dec 2011 18:03:03 +0000 (20:03 +0200)]
Messaging implementation based on akka-amqp
Georgios Gousios [Tue, 6 Dec 2011 15:50:38 +0000 (17:50 +0200)]
Fix failing test (forgot to init the DSL parser)
Georgios Gousios [Tue, 6 Dec 2011 15:41:07 +0000 (17:41 +0200)]
Load generator for the accounting service
Georgios Gousios [Tue, 6 Dec 2011 13:10:35 +0000 (15:10 +0200)]
Fix test: forgot to define an agreement
Georgios Gousios [Tue, 6 Dec 2011 12:36:03 +0000 (14:36 +0200)]
Method to align charge chunks between algorithm/pricelist
Georgios Gousios [Tue, 6 Dec 2011 09:00:11 +0000 (11:00 +0200)]
Fix expected result in test case
Christos KK Loverdos [Tue, 6 Dec 2011 15:11:55 +0000 (17:11 +0200)]
Move the messaging API one package up.
Since we have decided we are AMQP-based anyway, AMQP rules.
Christos KK Loverdos [Tue, 6 Dec 2011 13:09:58 +0000 (15:09 +0200)]
Remove unused camel tests (see previous commit)
Christos KK Loverdos [Tue, 6 Dec 2011 13:09:16 +0000 (15:09 +0200)]
Add Camel tests just to be there in history
Christos KK Loverdos [Tue, 6 Dec 2011 13:06:41 +0000 (15:06 +0200)]
Checkin to fix compilation
Christos KK Loverdos [Tue, 6 Dec 2011 12:15:51 +0000 (14:15 +0200)]
Remove finagle dependency
Christos KK Loverdos [Tue, 6 Dec 2011 12:15:21 +0000 (14:15 +0200)]
Remove camel dependencies
Christos KK Loverdos [Tue, 6 Dec 2011 11:59:56 +0000 (13:59 +0200)]
The ping test is actually a modification of the spray test.
Christos KK Loverdos [Tue, 6 Dec 2011 11:55:22 +0000 (13:55 +0200)]
Spray REST test plays OK