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

88 commits

Author SHA1 Message Date
Viktor Klang
2642c9a9cc Adding support for retrieving interfaces proxied and the current implementation behind the proxy, intended for annotation processing etc 2011-05-24 12:18:58 +02:00
Jonas Bonér
96367d9575 Merge branch 'master' of github.com:jboner/akka 2011-05-23 22:35:15 +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
39481f0a5f Adding a test to verify usage of TypedActor.self outside of a TypedActor 2011-05-23 18:10:57 +02:00
Viktor Klang
e320825137 Added some API to be able to wrap interfaces on top of Actors, solving the ActorPool for TypedActor dilemma, closing ticket #724 2011-05-23 17:08:45 +02:00
Viktor Klang
19cf26b6a9 Rewriting one of the tests in ActorRegistrySpec not to use non-volatile global state for verification 2011-05-23 12:08:38 +02:00
Viktor Klang
3b8c39582a Adding assertions to ensure that the registry doesnt include the actor after stop 2011-05-23 11:59:17 +02:00
Viktor Klang
8a790b1ddf Renaming CompletableFuture to Promise, Renaming AlreadyCompletedFuture to KeptPromise, closing ticket #854 2011-05-23 11:31: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
Viktor Klang
cd3cb8cd57 Renaming akka.routing.Dispatcher to Router, as per ticket #729 2011-05-20 12:29:48 +02:00
Viktor Klang
f9a335ea13 Adding support for obtaining the reference to the proxy of the currently executing TypedActor, this is suitable for passing on a safe alternative to _this_ 2011-05-20 11:45:14 +02:00
Roland
4809b63fda fix bad move of CallingThreadDispatcherModelSpec 2011-05-19 23:08:39 +02:00
Roland
a48f6fdf90 add copyright headers 2011-05-19 21:34:21 +02:00
Viktor Klang
e3daf11425 Removed some more boilerplate 2011-05-19 18:50:28 +02:00
Viktor Klang
d3e85f079b Implementing the typedActor-methods in ActorRegistry AND added support for multi-interface proxying 2011-05-19 16:53:40 +02:00
Viktor Klang
c49498f463 Merge with master 2011-05-19 14:30:41 +02:00
Viktor Klang
236d8e07e9 Removing the old typed actors 2011-05-19 14:29:21 +02:00
Jonas Bonér
76d9c3c33a 1. Added docs on how to run the multi-jvm tests 
2. Fixed cyclic dependency in deployer/cluster boot up
3. Refactored actorOf for clustered actor deployment, all actorOf now works
 2011-05-19 10:58:30 +02:00
Jonas Bonér
a7311c83e6 Added Scalariform sbt plugin which formats code on each compile. Also checking in reformatted code 2011-05-18 17:25:30 +02:00
Jonas Bonér
2af5097b87 Added command line options for setting 'nodename', 'hostname' and 'remote-server-port' when booting up an Akka node/microkernel 2011-05-18 14:15:17 +02:00
Peter Vlugter
ca7aea96a6 Bump version to 2.0-SNAPSHOT 2011-05-18 12:44:37 +12:00
Jonas Bonér
5d88ffe9d4 Merge branch 'wip-2.0' 2011-05-17 12:04:05 +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
Roland
e6f2870449 add some tests for Duration 2011-05-16 22:43:52 +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
Viktor Klang
5b54de7f48 Changing signature of traverse and sequence to return java.lang.Iterable, updated docs as well, closing #847 2011-05-11 13:29:29 +02:00
Viktor Klang
c0efbc690f Adding some tests to make sure that the Future Java API doesn`t change breakingly 2011-05-10 19:19:13 +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
Derek Williams
d0b27c43b7 Use Promise in tests 2011-05-03 18:52:58 -06:00
Derek Williams
5b18f18ffd Fix bug with 'Future << x', must be used within a 'flow' block now 2011-05-03 18:49:14 -06: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
Derek Williams
67f1e2fbca Fix Future.flow compile time type safety 2011-05-02 14:44:40 -06:00
Derek Williams
846d63aa92 Merge branch 'master' into delimited-continuations 
Conflicts:
	akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
	akka-actor/src/main/scala/akka/dispatch/Future.scala
	project/build/AkkaProject.scala
 2011-04-30 08:59:45 -06:00
Patrik Nordwall
6576cd51e9 Scala style fixes, added parens for side effecting shutdown methods 2011-04-29 10:20:16 +02:00
Viktor Klang
7d5bc13163 Removing uses of awaitBlocking in the FutureSpec 2011-04-28 16:23:03 +02:00
Viktor Klang
4bedb4813d Fixing tickets #816, #814, #817 and Dereks fixes on #812 2011-04-28 16:01:11 +02:00
Derek Williams
485013a353 Dispatcher executed Future will be cleaned up even after expiring 2011-04-27 20:45:39 -06:00
Derek Williams
43fc3bf463 Add failing test for Ticket #812 2011-04-27 19:39:15 -06:00
Viktor Klang
800840719f Making it impossible to complete a future after its expired, and not run onComplete callbacks if it hasnt been completed before expiry, fixing ticket #811 2011-04-27 16:52:19 +02:00
Viktor Klang
2da27123ac Renaming a test 2011-04-27 16:46:06 +02:00
Viktor Klang
82a11110d3 Removing awaitValue and valueWithin, and adding await(atMost: Duration) 2011-04-27 15:34:42 +02:00
Viktor Klang
5068f0d48a Removing blocking dequeues from MailboxConfig due to high risk and no gain 2011-04-27 12:21:19 +02:00
Jonas Bonér
868ec62ee7 Rebased from master branch 2011-04-27 01:06:08 +02:00
Jonas Bonér
9706d17ac1 Added Deployer with DeployerSpec which parses the deployment configuration and adds deployment rules 2011-04-27 00:40:20 +02:00
Jonas Bonér
2e7c76dd98 Rebased from master 2011-04-27 00:38:10 +02:00
Patrik Nordwall
bce7d176f4 Added parens to override of preStart and postStop 2011-04-26 20:31:08 +02:00
Jonas Bonér
4557f0d77a Deployer and deployment config parsing complete, test passing 2011-04-26 17:14:39 +02:00