Commit graph

98 commits

Author SHA1 Message Date
Roland
34a0f005b1 Merge branch 'master' into wip-1581-patterns-ask 2012-01-20 19:29:17 +01:00
Viktor Klang
8dfe619140 #1703 & #1693 - moving daemonicity to one place, and in doing so creating a thread factory in ActorSystem 2012-01-20 12:30:19 +01:00
Viktor Klang
149fbea5a7 Updating Copyright as per #1660 2012-01-19 18:21:06 +01:00
Roland
1daaee98aa Merge remote-tracking branch 'origin/master' into wip-1581-patterns-ask 2012-01-18 14:20:13 +01:00
Roland
2bed2cb954 move everything into package akka.pattern 2012-01-18 10:18:51 +01:00
Patrik Nordwall
e7a0247c0d Handle remote routers transparently. See #1606
* RemoteRouterConfig wrapper with RemoteRouteeProvider instead if fixed remote routers.
* Had to refactor and introduce RouteeProvider for different implementations of how to create routees.
* Works with Resizer also.
* Added some tests.
2012-01-17 09:11:45 +01:00
Patrik Nordwall
8d10d44929 Support config of custom router. See #1623 2012-01-12 16:37:08 +01:00
Patrik Nordwall
2399f02531 Improvements based on feedback. See #1619 2012-01-12 09:53:53 +01:00
Patrik Nordwall
6a12fb7876 Implemented SmallestMailboxRouter. See #1619 2012-01-11 14:06:47 +01:00
Patrik Nordwall
409cbaf8e2 Removed exposure of RoutedActorRef in RouterConfig. See #1618 2012-01-11 11:30:32 +01:00
Patrik Nordwall
762a6017e9 Verify config override of router nr-of-instances. See #1607
* It wasn't a bug. I think the confusion came from config without 'router' defined.
* Added test
* Added some clarification to docs
2012-01-10 17:50:17 +01:00
Patrik Nordwall
ed2b65c402 DOC: Routing (Java). See #1600 2012-01-05 17:59:19 +01:00
Nikolay Botev
ce1d2f4721 akka.patterns.ask everywhere 2012-01-01 22:23:19 -08:00
Viktor Klang
88d2427b7f Fixing race in ActorTimeoutSpec and a shadowing import in RoutingSpec 2011-12-30 11:25:39 +01:00
Roland
c4f3a93268 implement routing.FromConfig, see #1554 2011-12-29 17:23:35 +01:00
Henrik Engstrom
1a8e755738 Minor updates after further feedback. See #1529 2011-12-21 11:46:39 +01:00
Henrik Engstrom
dac0beb01b Updates based on feedback - use of abstract member variables specific to the router type. See #1529 2011-12-21 10:03:26 +01:00
Henrik Engstrom
0dc161c800 Initial take on removing hardcoded value from SGFCR. See #1529 2011-12-20 19:57:42 +01:00
Henrik Engstrom
c92f3c5ca2 Merge branch 'master' into 1495-routees-message-he
Conflicts:
	akka-actor/src/main/scala/akka/routing/Routing.scala
2011-12-20 11:18:37 +01:00
Henrik Engstrom
f67a50074b Removed racy test. See #1495 2011-12-19 18:35:48 +01:00
Henrik Engstrom
5aa4784ea2 Updated code after feedback; the actual ActorRef's are returned instead of the name of them. See #1495 2011-12-19 16:35:35 +01:00
Viktor Klang
c904fd3913 Making TestLatch Awaitable and fixing tons of tests 2011-12-19 15:05:33 +01:00
Henrik Engstrom
3ff779cabd Added functionality for a router client to retrieve the current routees of that router. See #1495 2011-12-19 14:20:33 +01:00
Viktor Klang
42e8a4559e #1496 - Rename 'targets' to 'routees' 2011-12-17 16:33:29 +01:00
Henrik Engstrom
95574dab7e Fixed failing test class. 2011-12-15 21:24:10 +01:00
Henrik Engstrom
536659d64c Fixed last(?) comments on the pull request. Fixes #1063 2011-12-15 20:42:51 +01:00
Henrik Engstrom
d68777e76e Updated after feedback. See #1063 2011-12-15 18:21:56 +01:00
Henrik Engstrom
41ce42c8f7 Upgraded routing documentation to Akka 2.0. See #1063 2011-12-15 16:36:04 +01:00
Jonas Bonér
b4f1978b37 Merge remote-tracking branch 'origin/wip-simplify-configuring-new-router-in-props-jboner'
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-12-15 10:32:31 +01:00
Viktor Klang
e959493e12 Enormous merge with master which probably led to the indirect unfortunate deaths of several kittens 2011-12-14 17:36:39 +01:00
Jonas Bonér
80600abc33 Added 'withRouter[TYPE]' to 'Props'.
Added docs (Scala and Java) and (code for the docs) for 'Props'.
Renamed UntypedActorTestBase to UntypedActorDocTestBase.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-12-14 14:05:44 +01:00
Roland
cb85778b12 remove ActorRef.stop()
- replace ActorRef.stop() by ActorRefFactory.stop(child) everywhere
- ActorCell “optimizes” this to remove the child from its childrenRefs
  in order to allow immediate recycling of the name
- the lost soul must have a place, for which the Locker has been
  created, where Davy Jones will happily rebind the soul to his ship
  (i.e. set “parent” to the locker to avoid mem leak) and periodically
  revisit it (.stop(), in case of that being lost in comm failure,
  similar .watch() to re-check liveness)
2011-12-14 00:10:53 +01:00
Roland
92e7693203 Merge remote-tracking branch 'origin/master' into wip-remote-supervision-rk 2011-12-13 16:59:43 +01:00
Roland
134fac4bfe make routers monitor their children 2011-12-13 16:05:56 +01:00
Jonas Bonér
c9b787f029 Removed all 'actorOf' methods that does not take a 'Props', and changed all callers to use 'actorOf(Props(..))'
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-12-13 14:09:40 +01:00
Roland
4bd9f6ae1a rename Props.withRouting to .withRouter 2011-12-13 11:32:24 +01:00
Roland
d1a26a9e28 implement remote routers
- split out actual routing functionality into *Like traits to be
  reusable
- make RemoteRouterConfig which only differs in how remote placement is
  initiated
- teach RemoteDeployer how to convert local RouterConfig in case config
  key “target.nodes” is set
- IT WORKS! All tests GREEN
- oh, yeah, had to make ActorPath serializable ...
2011-12-13 01:29:05 +01:00
Roland
0a7e5fe296 wrap up local routing
- pull some more generic stuff out of the individual routers, add
  factories which take only target lists
- add router parsing to Deployer, removing everything which is not
  strictly related to local scope, which left only few things, so move
  them to Deployer.scala and delete DeploymentConfig
- fix ConfiguredLocalRoutingSpec to use the new configuration mechanism
  and verify that configuration overrides code
- fix DeployerSpec by using (mostly) correct lookup paths and removing
  everything which was not local
- change config file layout, removing everything which is not local from
  akka-actor/.../reference.conf, putting the remote stuff into the
  akka-remote/.../reference.conf (unused as of yet); adapt comments
  according to changed functionality
2011-12-12 23:34:52 +01:00
Viktor Klang
b32cbbc764 Renaming Block to Await, renaming sync to result, renaming on to ready, Await.ready and Await.result looks and reads well 2011-12-12 22:50:08 +01:00
Viktor Klang
d8fe6a5509 Removing Future.get 2011-12-12 22:24:17 +01:00
Henrik Engstrom
192f84df71 Misc improvements of ActorRoutedRef. Implemented a scatterer gatherer router. Enabled router related tests. See #1440. 2011-12-12 15:06:40 +01:00
Henrik Engstrom
a7886abdf0 Implemented a couple of router types. Updated some tests. See #1440 2011-12-11 22:40:28 +01:00
Henrik Engstrom
90b6833978 Initial take on new routing implementation. Please note that this is work in progress! 2011-12-09 14:46:57 +01:00
Patrik Nordwall
f7d6393027 Removed actorOf methods from AkkaSpec. See #1439 2011-12-07 11:10:54 +01:00
Patrik Nordwall
3204269f6a Cleanup of methods in Actor and ActorContext trait. See #1377
* Added JavaActorContext, UntypedActor.getContext
* implicit val context in Actor needs to be implicit to support forward,
it would be nice if it wasn't implicit because now I can't override context
in UntypedActor
* Removed implicit def system in Actor
* Removed implicit def defaultTimeout in Actor
* Removed receiveTimeout, children, dispatcher, become, unbecome, watch,
unwatch in Actor
* Removed corresponding as above from UntypedActor
* Removed implicit from dispatcher in ActorSystem
* Removed implicit def timeout in TypedActor
* Changed receiveTimeout to use Duration (in api)
* Changed many tests and samples to match new api
2011-12-06 09:50:16 +01:00
Jonas Bonér
0a1740cd6d Merge branch 'master' of github.com:jboner/akka
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-11-24 21:05:41 +01:00
Jonas Bonér
ef6c8370cd Added BroadcastRouter which broadcasts all messages to all the connections it manages, also added tests.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-11-24 16:35:37 +01:00
Viktor Klang
c56341b3a6 Fixing FIXME to rename isShutdown to isTerminated 2011-11-23 19:03:56 +01:00
Roland
648661c548 clean up initialization of ActorSystem, fixes #1050
- create ActorSystemImpl trait to make ActorSystem fully abstract
- add Java API for constructing (ActorSystem.create(...))
- only go through factory methods because .start() has become necessary
- rename all user-facing occurrences of “app” to “system” (Actor trait
  and TestKit/AkkaSpec)
- pass ActorSystemImpl to ActorRefs upon creation, which means that
  actorOf() and friends need such an argument, which must be provided to
  the ActorRefProvider by the ActorRefFactory implementation
2011-11-16 17:18:36 +01:00
Jonas Bonér
e88d07305d Cleaned up RoutedProps and removed all actorOf methods with RoutedProps.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-11-11 19:57:27 +01:00