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

7267 commits

This branch
This branch
All branches
Author SHA1 Message Date
Peter Vlugter
bbb9bc2c5e Manually fix protocols for scaladoc generation. See #1017 2011-08-29 15:43:55 +02:00
Patrik Nordwall
7da2341bed Use slf4j logger from the incoming instance.getClass.getName. Fixes #1121 
* Different logger based on incoming event.
* Removed format, since that should be in logback configuration.
* The stackTrace is now logged with the error(msg, throwable) method.
 2011-08-29 14:47:25 +02:00
Jonas Bonér
5e290ec393 Merge branch 'master' of github.com:jboner/akka 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-29 14:26:24 +02:00
Jonas Bonér
933e4f4323 Added initial (very much non-complete) version of failure detection management system. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-29 12:02:12 +02:00
Jonas Bonér
c797f2a3e2 Added Thread name to the formatting of Slf4j handler. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-29 12:00:59 +02:00
Jonas Bonér
640487bc79 Removed Tab and Newline from formatting in Slf4j handler. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-29 11:47:26 +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
Peter Veentjer
650e78b2f7 Merge ClusterActoRef & RoutedActorRef: After merge with master, part 2 2011-08-29 12:07:34 +03:00
Peter Veentjer
56d4fc7d7c Merge ClusterActoRef & RoutedActorRef: After merge with master 2011-08-29 09:22:14 +03:00
Patrik Nordwall
e2ef8404b2 Added disclaimer about typesafe repo, and info about underlaying repositories. See #1127 
(cherry picked from commit 11aef33e3913aee922b78fcc684416a03439d9a5)
 2011-08-28 22:19:00 +02:00
Vasil Remeniuk
3cee2fc8ec Internal Metrics API. Fixes #939 
* Retreives metrics snapshots of the system the node is running on through JMX monitoring MBeans or Hyperic Sigar (is Sigar library is plugged)
        * Allows to set metrics alteration monitors that are triggered, when specific conditions are satisfied (e.g., not enough memory left on the node)
        * Nodes publish their local metrics to ZNodes
        * In order to maintain good performance, metrics manager internally caches snapshots, and refreshes them from time to time from ZooKeeper
 2011-08-28 16:07:19 +03:00
Peter Veentjer
ee4d241ceb Use RoutedProps to configure Routing (local and remote). Ticket #1060 2011-08-27 08:10:25 +03:00
Viktor Klang
cb9196c690 #1146 - Switching from STringBuffer to StringBuilder for AkkaException 2011-08-26 17:52:29 +02:00
Viktor Klang
6bd4a9f68b Removing the dispatcher from inside the EventHandler 2011-08-26 17:37:28 +02:00
Viktor Klang
fa5d521066 Merge branch 'master' of github.com:jboner/akka 2011-08-26 17:36:18 +02:00
Viktor Klang
c7d58c600b Adding initial support for Props 2011-08-26 17:25:18 +02:00
Patrik Nordwall
35ba837f7f Updated documentation for use with sbt 0.10. Merge from 1.2 branch to master. See #1127 2011-08-26 14:15:03 +02:00
Martin Krasser
fabc0a1b72 Upgrade to Camel 2.8.0 2011-08-26 11:28:49 +02:00
Viktor Klang
4bc0cfe0bf Revert "Fixing erronous cherry-pick change in EventHandler" 
This reverts commit 95976b4f6b.
 2011-08-26 10:23:36 +02:00
Jonas Bonér
43bbc199b2 Merge branch 'master' of github.com:jboner/akka 2011-08-26 08:31:23 +02:00
Jonas Bonér
a4c66bb4d9 Minor changes to logging and reformatting. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-26 08:24:26 +02:00
Jonas Bonér
2646ecd14a Fixed bug in Cluster; registration of actor address per node mapping was done in wrong order and using ephemeral node. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-26 08:23:56 +02:00
Jonas Bonér
9ade2d7f57 Fixed bug in NettyRemoteSupport in which we swallowed Netty exceptions and treated them as user exceptions and just completed the Future with the exception and did not rethrow. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-26 08:21:12 +02:00
Jonas Bonér
fe1d32b605 Rewrote RandomFailoverMultiJvm and RoundRobinFailoverMultiJvm to use polling instead of Thread.sleep. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-25 16:17:05 +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
Viktor Klang
95976b4f6b Fixing erronous cherry-pick change in EventHandler 2011-08-25 14:35:54 +02:00
Viktor Klang
b0d0e966c4 Merge branch 'master' of github.com:jboner/akka 2011-08-25 14:06:11 +02:00
Viktor Klang
79b663f31f #1143 - Fixing EventHandler.levelFor by switching to isAssignableFrom" 2011-08-25 14:05:53 +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
Jonas Bonér
9a5b1a88e6 Added explicit call to Cluster.node.start() in various tests. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 21:51:18 +02:00
Jonas Bonér
60f55c7c36 Switched from Thread.sleep to Timer.isTicking in various tests. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 21:50:23 +02:00
Jonas Bonér
f9e82eaee5 Added method to ClusterNode to check if an actor is checked out on a specific (other) node, also added 'start' and 'boot' methods. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 21:48:47 +02:00
Jonas Bonér
aeb8178007 Added Timer class to be used in testing and more. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 21:45:41 +02:00
Jonas Bonér
5eeda5bf40 Refactored and enhanced EventHandler with optional synchronous logging to STDOUT to be used during testing and debugging sessions. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 21:44:35 +02:00
Jonas Bonér
775099a3a8 Merge branch 'master' of github.com:jboner/akka 2011-08-24 13:01:44 +02:00
Jonas Bonér
c20acef4c1 Fixed completely broken spec: ClusterActorRefCleanupMultiJvmSpec. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 12:47:00 +02:00
Jonas Bonér
4c8b46db88 Added preferred node to ReplicationTransactionLogWriteThroughNoSnapshotMultiJvmSpec to make it more stable. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 12:46:19 +02:00
Jonas Bonér
472b505077 Adding ClusterActorRef to ActorRegistry. Renamed Address to RemoteAddress. Added isShutdown flag to ClusterNode. Fixes #1132. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 12:45:32 +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
Viktor Klang
b76c02d136 #1139 - Added akka.actor.DefaultBootableActorLoaderService for the Java API 2011-08-24 12:42:26 +02:00
Jonas Bonér
53b4942dde Removed unused Routing.scala file. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 12:41:50 +02:00
Jonas Bonér
3ae7b522b8 Removed logging in startup of TransactionLog to avoid triggering of cluster deployment. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 12:39:56 +02:00
Jonas Bonér
8475561102 Build RemoteProtocol protobuf classes for Protobuf 2.4.1 2011-08-23 12:39:51 +02:00
Jonas Bonér
22738a242d Changed style of using empty ZK barrier bodies from 'apply()' to 'await()' 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-19 17:55:49 +02:00
Jonas Bonér
0ad8e6e38f Moved the Migration multi-jvm test to different package. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-19 17:52:26 +02:00
Jonas Bonér
b361a79348 Removed MigrationAutomaticMultiJvmSpec since the same thing is tested in a better way in the router fail-over tests. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-19 17:51:45 +02:00
Jonas Bonér
6c7c3d43a6 Fixed problem with ClusterActorRefCleanupMultiJvmSpec: added missing/unbalanced barrier. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-19 17:50:11 +02:00
Jonas Bonér
8ca638e527 Merge branch 'master' of github.com:jboner/akka 2011-08-19 17:28:52 +02:00
Jonas Bonér
4a011ebdac Fixed race problem in actor initialization in Random3ReplicasMultiJvmSpec. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-19 17:28:38 +02:00
Jonas Bonér
fcc3e410b4 Fixed problems with RandomFailoverMultiJvmSpec. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-19 17:24:08 +02:00