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

288 commits

Author SHA1 Message Date
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
Heiko Seeberger
28bce69c62 closes #689: All properties from the configuration file are unit-tested now. 2011-03-08 15:23:58 +01:00
Heiko Seeberger
ebc8ccba84 re #689: Verified config for akka-stm. 2011-03-08 15:23:05 +01:00
Heiko Seeberger
95c2b0446e re #689: Verified config for akka-remote. 2011-03-08 15:23:05 +01:00
Heiko Seeberger
9d63964a39 re #689: Verified config for akka-http. 2011-03-08 15:23:05 +01:00
Heiko Seeberger
031b5c22ef re #689: Verified config for akka-actor. 2011-03-08 15:23:05 +01:00
Jonas Bonér
bc5449d368 Merge branch 'master' of github.com:jboner/akka 2011-03-07 12:29:08 +01:00
Jonas Bonér
2168e861bf Changed event handler config to a list of the FQN of listeners 2011-03-07 12:18:00 +01:00
Peter Vlugter
53c824d1e8 Remove logback config 2011-03-04 18:04:15 +01:00
Peter Vlugter
7fb69587de Incorporate configgy with some renaming and stripping down 2011-03-03 07:43:25 +01:00