raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11
6851 commits 1 branch 31 tags 268 MiB
Commit graph

297 commits

Author SHA1 Message Date
Brendan W. McAdams
2a56322814 Migrate to Hammersmith (com.mongodb.async) URI Format based URLs; new 
config options
    - Mongo URI config options
    - Configurable timeout values for Read and Write
 2011-07-11 20:02:14 -04:00
Brendan W. McAdams
87d1094f84 Merge branch 'master' of https://github.com/jboner/akka 2011-07-09 09:58:13 -04:00
Jonas Bonér
0b1ee758f5 1. Implemented replication through transaction log, e.g. logging all messages and replaying them after actor migration 
2. Added first replication test (out of many)
3. Improved ScalaDoc
4. Enhanced the remote protocol with replication info

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-07-08 08:28:13 +02:00
Brendan W. McAdams
7eecff5963 Merge branch 'master' of github.com:bwmcadams/akka 2011-07-05 20:20:15 -04:00
Brendan W. McAdams
1f4cf472ba First pass at Mongo Durable Mailboxes in a "Naive" approach. Some bugs 
in Hammersmith currently surfacing that need resolving.
 2011-07-05 20:19:47 -04:00
Jonas Bonér
f2dd6bddb3 1. Added configuration option for 'preferred-nodes' for a clustered actor. The replica set is now tried to be satisfied by the nodes in the list of preferred nodes, if that is not possible, it is randomly selected among the rest. 
2. Added test for it.
3. Fixed wrong Java fault-tolerance docs
4. Fixed race condition in maintenance of connections to new nodes

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-07-05 13:28:02 +02:00
Roland
1e4084e843 document logging and testing settings 2011-06-19 17:08:50 +02:00
Jonas Bonér
204f4e2c4c reformatted akka-reference.conf 2011-06-15 13:37:31 +02:00
Debasish Ghosh
a7dffdd445 pluggable serializers - changed entry name in akka.conf to serialization-bindings. Also updated akka-reference.conf with a commented section on pluggable serializers 2011-06-15 13:42:22 +05:30
Jonas Bonér
bf0515b8e5 Fixed remaining issues in pluggable serializers (cluster impl) 2011-06-14 19:35:18 +02:00
Viktor Klang
fa0478bc32 Replacing !!! with ? 2011-06-13 13:43:21 +02:00
Viktor Klang
fd5afde4ff Adding 'ask' to replace 'sendRequestReplyFuture' and removing sendRequestReply 2011-06-13 13:28:29 +02:00
Viktor Klang
5e192c5376 Adding microkernel-server.xml to Akka since kernel has moved here 2011-06-12 12:52:44 +02:00
Jonas Bonér
5006f8e3b0 renamed 'remote' module config option to 'cluster' + cleaned up config file comments 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-10 21:01:19 +01:00
Jonas Bonér
5c92a2704d Moved 'akka.remote' config elements into 'akka.cluster' 2011-06-10 20:49:00 +01:00
Jonas Bonér
8098a8d9be Added storage models to remote protocol and refactored all clustering to use it. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-10 16:31:24 +01:00
Jonas Bonér
7dbc5ac958 Merged with master 2011-06-10 08:41:10 +02:00
Jonas Bonér
04efc440d6 1. Made LocalActorRef aware of replication 
2. Added configuration for transaction log replication
3. Added replication schemes WriteThrough and WriteBehind
4. Refactored serializer creation and lookup in Actor.scala
5. Extended network protocol with replication strategy
6. Added BookKeeper management to tests
7. Improved logging and error messages
8. Removed ReplicatedActorRef
9. Added snapshot management to TransactionLog

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-07 11:10:29 -07:00
Viktor Klang
c3ee1244be Removing the Jersey Http Security Module plus the AkkaRestServlet 2011-06-05 19:29:46 -07:00
Jonas Bonér
112ddefd7d refactoring and minor edits 2011-05-30 10:53:25 +02:00
Jonas Bonér
e6fa55b3a8 - Changed implementation of Actor.actorOf to work in the the new world of cluster.ref, cluster.use and cluster.store. 
- Changed semantics of replica config. Default replicas is now 0. Replica 1 means one copy of the actor is instantiated on another node.
- Actor.remote.actorFor/Actor.remote.register is now separated and orthogonal from cluster implementation.
- cluster.ref now creates and instantiates its replicas automatically, e.g. it can be created first and will then set up what it needs.
- Added logging everywhere, better warning messages etc.
- Each node now fetches the whole deployment configuration from the cluster on boot.
- Added some config options to cluster

Signed-off-by: Jonas Bonér <jonasremove@jonasboner.com>
 2011-05-25 16:18:35 +02:00
Jonas Bonér
ddb2a69c19 Moved ClusterNode interface, NodeAddress and ChangeListener into akka-actor as real Trait instead of using structural typing. 
Refactored boot dependency in Cluster/Actor/Deployer.
Added multi-jvm test for testing clustered actor deployment, check out as LocalActorRef and ClusterActorRef.

Signed-off-by: Jonas Bonér <jonasremove@jonasboner.com>
 2011-05-23 22:35:01 +02:00
Viktor Klang
3181905fed Renaming EBEDD to Dispatcher, EBEDWSD to BalancingDispatcher, ThreadBasedDispatcher to PinnedDispatcher and PEBEDD to PriorityDispatcher, closing ticket #784 2011-05-20 22:56:30 +02:00
Jonas Bonér
cd18e72342 Fixed issues with 'ClusterNode.use(address): ActorRef'. 
Various other fixes and minor additions.

Signed-off-by: Jonas Bonér <jonasremove@jonasboner.com>
 2011-05-20 17:13:39 +02:00
Peter Vlugter
ca7aea96a6 Bump version to 2.0-SNAPSHOT 2011-05-18 12:44:37 +12:00
Jonas Bonér
160ff867cb Added durable mailboxes: File-based, Redis-based, Zookeeper-based and Beanstalk-based 2011-05-17 14:48:06 +02:00
Jonas Bonér
7cf3d0876d Added tests for usage of cluster actor plus code backing the test. 
Added more cluster API to ReflectiveAccess.
Plus misc refactorings and cleanup.
 2011-05-17 11:05:09 +02:00
Jonas Bonér
2655d44ee9 Merged wip-2.0 branch with latest master 2011-05-16 12:32:00 +02:00
Jonas Bonér
6c6089e081 Misc fixes everywhere; deployment, serialization etc. 2011-05-16 09:47:23 +02:00
Patrik Nordwall
5b08cf5907 Removed jta section from akka-reference.conf 
(cherry picked from commit 3518f4ffbbdda8ddae26e394604f7e0d22324a38)
 2011-05-09 08:29:12 +02:00
Peter Vlugter
9ace0a97da Bump version to 1.2-SNAPSHOT 2011-05-06 14:01:21 +12:00
Jonas Bonér
d50ab24b11 Changed the 'home' cluster config option to one of 'host:<hostname>', 'ip:<ip address>'' or 'node:<node name>' 2011-05-04 21:25:47 +02:00
Jonas Bonér
bd5cc53235 Clustered deployment in ZooKeeper implemented. Read and write deployments from cluster test passing. 2011-05-03 21:04:45 +02:00
Viktor Klang
4bedb4813d Fixing tickets #816, #814, #817 and Dereks fixes on #812 2011-04-28 16:01:11 +02:00
Jonas Bonér
4557f0d77a Deployer and deployment config parsing complete, test passing 2011-04-26 17:14:39 +02:00
Jonas Bonér
d1bdddd588 mid address refactoring 2011-04-20 09:04:57 +02:00
Jonas Bonér
3374eef6ce Merged with Viktors work with removing client managed actors. Also removed actor.id, added actor.address 2011-04-08 21:16:05 +02:00
Jonas Bonér
0149cb3fee Changed logging level in ReflectiveAccess and set the default Akka log level to INFO 2011-04-01 15:49:33 +02:00
Jonas Bonér
dcd49bd052 Added configuration to define capacity to the remote client buffer messages on failure to send 2011-03-29 17:07:41 +02:00
Jonas Bonér
9cdf58acad Merge branch 'master' of github.com:jboner/akka 2011-03-28 09:22:03 +02:00
Jonas Bonér
0412ae4151 Renamed config option for remote client retry message send. 2011-03-28 09:05:16 +02:00
Jonas Bonér
cf80e6a33d 1. Added config option to enable/disable the remote client transaction log for resending failed messages. 
2. Swallows exceptions on appending to transaction log and do not complete the Future matching the message.
 2011-03-27 22:58:50 +02:00
Jonas Bonér
a8991ac538 Merge branch 'master' of github.com:jboner/akka 2011-03-23 15:12:32 +01:00
Jonas Bonér
6429086b51 Moved EventHandler to 'akka.event' plus added 'error' method without exception param 2011-03-23 15:12:09 +01:00
Viktor Klang
7efe2dc2ed Merge branch 'master' of github.com:jboner/akka 2011-03-23 11:31:50 +01:00
Viktor Klang
db1b50a6b6 Adding OrderedMemoryAwareThreadPoolExecutor with an ExecutionHandler to the NettyRemoteServer 2011-03-23 11:31:19 +01:00
Peter Vlugter
74f7d474ab Remove akka-specific transaction and hooks 2011-03-23 18:33:44 +13:00
Jonas Bonér
8264ba8257 Added generic event handler 2011-03-14 11:12:23 +01:00
Jonas Bonér
f8ce3d541e Changed API for EventHandler and added support for log levels 2011-03-14 10:45:49 +01:00
Viktor Klang
93470f303b Removing ssl options since SSL isnt ready yet 2011-03-08 15:24:56 +01:00