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

39 commits

Author SHA1 Message Date
Viktor Klang
93d093e87a Commenting out the ForkJoin stuff until I've cleared some bits with Doug Lea 2011-12-02 17:29:47 +01:00
Viktor Klang
bf7befc690 Sprinkling some final magic sauce 2011-12-01 23:43:56 +01:00
Viktor Klang
ef27f865d4 Adding support for ForkJoinPoolConfig so you can use ForkJoin 2011-12-01 17:03:30 +01:00
Viktor Klang
80d766b07b Adding DispatcherPrerequisites to hold the common dependencies that a dispatcher needs to be created 2011-11-17 16:09:18 +01:00
Roland
62032cb1ff merge system-cleanup into master 2011-11-17 14:38:49 +01:00
Viktor Klang
727c7de58d Removing bounded executors since they have probably never been used, also, removing possibility to specify own RejectedExecutionHandler since Akka needs to know what to do there anyway. Implementing a sane version of CallerRuns 2011-11-15 10:32:00 +01:00
Viktor Klang
a7e9ff4fba Switching to AbortPolicy by default 2011-11-14 19:48:06 +01:00
Viktor Klang
66dd0123bc Temporary fix for the throughput benchmark 2011-11-14 19:19:44 +01:00
Roland
f2bf27b4de remove app argument from Dispatchers 
(cascading into all dispatchers, mailboxes, other stuff; had to move
deadLetter stuff to ActorSystem again and split its initialization due
to cyclic dependency)
 2011-11-14 16:03:26 +01:00
Roland
53353d7031 rename MainBus to EventStream (incl. field in ActorSystem) 2011-11-10 21:01:37 +01:00
Roland
945b1aedf9 rename akka.AkkaApplication to akka.actor.ActorSystem 
Renaming it to System did not appeal after seeing that such a thing is
already imported from Predef ...
 2011-11-10 21:00:01 +01:00
Roland
f46c6dc533 introducing: MainBus feat. LoggingBus 
most tests passing, everything compiling, but docs not updated and nasty
thread-leak preventing me from running the whole test-suite (which is
the reason for this commit: I want to chase down that one first).

- the app.mainbus is classified by Class[_] (currently lookup, will
  possibly change to sub-class-aware) and accepts AnyRef messages
- LoggingBus handles akka.event-handlers from config specially:
  + start them as system services, supervised by SystemGuardian
  + keep their subscriptions in sync when logLevel_= is called
  + send them InitializeLogger(bus) message before subscribing them (so
    they can register for extras like Mute/UnMute)
- two-phased start-up: first phase with actor-less stdout logging, then
  subscription of config loggers, then remove stdout logger (logLevels
  configurable separately)
- MainBusReaper watches registered receivers and unsubscribes them upon
  death (started in phase 2)
- logger factory on Logging object, needs app/bus and log source;
  default instance in app.log
 2011-10-27 12:36:22 +02:00
Roland
44b94643e5 Merge with Peter's work (i.e. merging master into tame-globals) 2011-10-13 14:17:07 +02:00
Roland
85b7accfd4 make EventHandler non-global 
- add Logging trait for nicer interface
- add EventHandlerLogging class for offering the nice interface from
  app.log
- add eventHandler instance to app and use that for all internal logging
  (this means that some places (dispatchers, remoting) were infiltrated
  by app just to do logging, but I think we'll need app in there soon
  enough for other reasons)
 2011-10-13 13:21:59 +02:00
Viktor Klang
3567d554fb Adding documentation for the ExecutorService and ThreadPoolConfig DSLs 2011-10-12 18:21:12 +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
Peter Veentjer
1c39ed1ad6 cleanup of unused imports 2011-08-13 08:27:10 +03:00
Viktor Klang
9d71be7778 Updating copyright section to Typesafe Inc. etc 2011-07-14 16:03:08 +02:00
Viktor Klang
522a163114 Adding support for daemonizing MonitorableThreads 2011-07-11 18:54:15 +02:00
Viktor Klang
fc51bc4864 Adding support for ForkJoin dispatcher as FJDispatcher 2011-07-01 22:36:39 +02:00
Jonas Bonér
85e742373a - Made ClusterActorRef not extends RemoteActorRef anymore 
- Refactored and cleaned up Transaction Log initialization

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-07 20:10:08 -07: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
2655d44ee9 Merged wip-2.0 branch with latest master 2011-05-16 12:32:00 +02:00
Peter Vlugter
6f17d2cf6d Fix @deprecated warnings 2011-05-06 11:55:58 +12:00
Patrik Nordwall
6576cd51e9 Scala style fixes, added parens for side effecting shutdown methods 2011-04-29 10:20:16 +02:00
Viktor Klang
3f49eadedc Removing more deprecation warnings and more client-managed actors residue 2011-04-07 13:03:23 +02:00
Jonas Bonér
3d529e8ca4 Added check to ensure that messages are not null. Also cleaned up misc code 2011-03-30 15:12:58 +02: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
Jonas Bonér
299f865156 Fixed bug with restarting supervised supervisor that had done linking in constructor + Changed all calls to EventHandler to use direct 'error' and 'warning' methods for improved performance 2011-03-18 23:04:48 +01:00
Jonas Bonér
f8ce3d541e Changed API for EventHandler and added support for log levels 2011-03-14 10:45:49 +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
Jonas Bonér
793ad9ac03 Renamed to EventHandler and added 'info, debug, warning and error' 2011-03-02 18:19:17 +01:00
Jonas Bonér
c4e2d73668 Added the ErrorHandler notifications to all try-catch blocks 2011-03-02 00:14:45 +01:00
Jonas Bonér
9354f0790c Removed logging 2011-02-28 22:54:32 +01:00
Viktor Klang
71596343c6 Minor code cleanup and deprecations etc 2011-01-05 16:36:50 +01:00
Jonas Bonér
e8fcdd697b Updated the copyright header to 2009-2011 2010-12-22 15:35:50 +01:00
Viktor Klang
bc1ae7814b Fixing all %s into {} for logging 2010-11-24 13:53:53 +01:00
Viktor Klang
08abc15e8a Switching to raw SLF4J on internals 2010-11-24 13:42:41 +01:00
Viktor Klang
7040ef0f14 Added a root akka folder for source files for the docs to work properly, closing ticket #541 2010-11-20 22:26:26 +01:00
Renamed from akka-actor/src/main/scala/dispatch/ThreadPoolBuilder.scala (Browse further)