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

321 commits

Author SHA1 Message Date
Jonas Bonér
85941c0d51 Changed 'deployment.clustered' to 'deployment.cluster' 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-09-14 17:47:52 +02:00
Peter Vlugter
0430e284a6 Get the (non-multi-jvm) cluster tests working again 
- avoid initialising the cluster in TransactionLog
- allow TransactionLog to be started and shutdown multiple times
- correct the startup and shutdown in the transaction log tests
 2011-09-08 17:19:27 +02:00
Jonas Bonér
0a63350452 Added configuration for failure detection; both via akka.conf and via Deploy(..). 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-31 15:07:18 +02:00
Jonas Bonér
0e063f0a1d Converted tabs to spaces. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-29 15:16:04 +02:00
Jonas Bonér
66f339e202 Moved all 'akka.remote' to 'akka.cluster', no more 'remote' package. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-29 11:44:33 +02:00
Jonas Bonér
66bb47db6a Changed akka.cluster.client.read-timout option. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-25 16:15:06 +02:00
Jonas Bonér
2c25f5d972 Changed remote client read timeout from 10 to 30 seconds. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-25 09:03:45 +02:00
Viktor Klang
a909bf8d08 #1140 - Adding support for specifying ArrayBlockingQueue or LinkedBlockingQueue in akka.conf and in the builder 2011-08-24 12:42:39 +02:00
Jonas Bonér
dfc1a68aac Fixed race condition in initial and dynamic management of node connections in Cluster 
* Using CAS optimistic concurrency using versioning to fix initial and dynamic management of node connections in Cluster
* Fixed broken bootstrap of ClusterNode - reorganized booting and removed lazy from some fields
* Removed 'start' and 'isRunning' from Cluster
* Removed 'isStarted' Switch in Cluster which was sprinkled all-over cluster impl
* Added more and better logging
* Moved local Cluster ops from Cluster to LocalCluster
* Rewrote RoundRobinFailoverMultiJvmSpec to be correct
* RoundRobinFailoverMultiJvmSpec now passes
* Minor reformatting and edits

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-18 11:35:14 +02:00
Viktor Klang
5138fa9764 Removing global dispatcher 2011-08-15 11:40:21 +02:00
Viktor Klang
37a6844d46 Changing default connection timeout to 100 seconds and adding Future Java API with tests 2011-08-12 17:26:26 +02:00
Jonas Bonér
5b2b463ce0 Changed the elements in actor.debug section in the config from receive = "false" to receive = off. Minor other reformatting changes 2011-08-12 14:35:45 +02:00
Viktor Klang
86bd9aaa51 Forward-porting documentation-fixes and small API problems from release-1.2 2011-08-11 19:29:57 +02:00
Peter Veentjer
eae045ff45 ticket 989 #Allow specifying preferred-nodes of other type than node:<name>/ 
currently the task has been downscoped to only allow node:name since we need to rethink this part. Metadata is going to make it /
it possible to deal with way more nodes
 2011-08-09 13:22:05 +03:00
Peter Veentjer
f1bc34cad7 ticket 989 #Allow specifying preferred-nodes of other type than node:<name>/ 
currently the task has been downscoped to only allow node:name since we need to rethink this part. Metadata is going to make it /
it possible to deal with way more nodes
 2011-08-09 13:19:59 +03:00
Viktor Klang
4cd4917f9f Turning remote compression off by default, closing ticket #1083 2011-08-07 19:23:25 +02:00
Peter Vlugter
b2bfe9a944 Some quietening of camel test output 2011-08-05 18:41:53 +12:00
Derek Williams
6d343b01f0 Merge branch 'master' into wip-derekjw 
Conflicts:
	akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
	akka-actor/src/main/scala/akka/actor/ActorRef.scala
 2011-07-26 12:50:09 -06:00
Peter Veentjer
e9f4c3ea46 ticket 974: Fix of the ambiguity problem in the Configuration.scala 2011-07-19 16:06:29 +03:00
Peter Veentjer
5635c9f76a ticket 974 2011-07-18 17:55:48 +03:00
Derek Williams
50dcdd411c Merge branch 'master' into wip-derekjw 
Conflicts:
	akka-actor-tests/src/test/scala/akka/misc/SchedulerSpec.scala
 2011-07-15 11:31:24 -06:00
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
Derek Williams
34ca784846 Merge branch 'master' into wip-derekjw 
Conflicts:
	akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
	akka-actor/src/main/scala/akka/actor/Actor.scala
	akka-actor/src/main/scala/akka/actor/ActorRef.scala
	akka-actor/src/main/scala/akka/actor/TypedActor.scala
	akka-actor/src/main/scala/akka/dispatch/Future.scala
 2011-07-11 13:02:42 -06: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
Derek Williams
23dcb5d1fe Merge branch 'master' into wip-derekjw 2011-06-19 14:49:50 -06:00
Roland
1e4084e843 document logging and testing settings 2011-06-19 17:08:50 +02:00
Derek Williams
6b73e0982a Added TestEventListener 2011-06-17 16:45:36 -06: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