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

270 commits

Author SHA1 Message Date
galarragas
8757838ad2 Post revision changes: 
- Added handling of termination of target actor
- Introduced a Passthrough command type to allow sending message to the target actor in any state. It is intended for control messages such as `PoisonPill` or `Kill`
 2015-12-31 20:57:42 +00:00
galarragas
ce7d76cec5 Post revision changes: 
- Reordered message cases for Closed state management
- Improved error message for unexpected self-sent circuit open message
 2015-12-31 19:24:26 +00:00
galarragas
36a420fcc8 Post revision changes: 
- Renamed the circuit breaker actor into a proxy for clarity and small renaming of the builder
- Added Java-friendly `with` copy methods to `CircuitBreakerPropsBuilder`
- Refactored a test not using the scenario trait as others
 2015-12-31 19:15:10 +00:00
galarragas
b1980992f9 Post revision changes: 
- Added reference to the circuit breaker pattern function in the CircuitBreakerActor scaladoc
- made `final` classes `OpenCircuitException` and `CircuitBreakerActor`
- Renamed `CircuitBreakerActorBuilder` into `CircuitBreakerActorPropsBuilder` and renamed the `propsForTarget` method into `props`
 2015-12-31 18:46:29 +00:00
Raymond Roestenburg
2404a9da01 #19246 Auto and manual reset and BackoffOptions. 
Also moved `TransparantExponentialBackoffSupervisor` to `akka.pattern` (renamed to `BackoffOnRestartSupervisor`)
 2015-12-29 21:23:16 +02:00
galarragas
fd5b872a43 Post revision changes: 
- Moved sample code in source files
- Text review
- Proper use of RST syntax
- Improved ScalaDoc
 2015-12-25 15:27:45 +00:00
galarragas
457ccc1250 Post revision changes: 
- Typo in documentation
- Made case classes `final`
- Hidden the actor's `log` with one passed as parameter to the method
 2015-12-25 10:00:03 +00:00
galarragas
1f4184e64b Adding to the contrib module an Proxy Actor implementing the circuit breaker pattern 2015-12-19 14:39:49 +00:00
Patrik Nordwall
ef03818ab1 =act #19016 use the BackoffSupervisor as sender for parent msg 2015-11-27 09:21:28 +01:00
kukido
7124b5dddf =doc #18899 code review follow-up, fixed typo 2015-11-11 09:26:00 -08:00
kukido
3cc3666724 =doc Fixes for genjavadoc 2015-11-11 00:29:44 -08:00
Henry Mai
a0e9b01aa4 Add TransparentExponentialBackoffSupervisor 2015-11-01 22:25:05 -08:00
Martynas Mickevičius
4ffe267835 =pro verify BC against all binary compatible versions 2015-10-23 09:10:25 +03:00
luben karavelov
3d277fc711 =con bind the contrib tests to random open port 2015-09-14 11:46:21 +02:00
Jeremy.Stone
b884dde6ee =con #17670 Fix potential ReceivePipeline MatchError 2015-08-18 17:55:02 +01:00
Konrad Malawski
c7c89f02ac =con #17414 doc mix-in order for PersistentActor and ReceivePipeline 2015-08-14 14:59:43 +02:00
Patrik Nordwall
b8ef08ae71 Merge pull request #17764 from akka/wip-17501-harden-ReliableProxySpec-patriknw 
=con #17501 Increase timeouts in ReliableProxySpec
 2015-06-18 11:16:10 +02:00
Patrik Nordwall
6fb74532b6 Merge pull request #17673 from jwcarman/jwcarman-add-osgi-contrib 
Adding OSGi metadata to contrib module.
 2015-06-18 11:15:03 +02:00
Patrik Nordwall
de5478cb21 =con #17501 Increase timeouts in ReliableProxySpec 2015-06-17 17:27:14 +02:00
Patrik Nordwall
d19f694821 Merge pull request #17490 from akka/wip-17010-logger-mailbox-patriknw 
=act #17010 Drain log messages on system shutdown
 2015-06-17 16:49:42 +02:00
Patrik Nordwall
156e2a0aea =act #17010 Drain log messages on system shutdown 
* by using a special mailbox that emits the remaining log messages
  to the StandardOutLogger
 2015-06-17 15:32:30 +02:00
James Carman
b537084de3 Adding OSGi metadata to contrib module. 2015-06-06 09:16:49 -04:00
Martynas Mickevičius
7fc2790458 =pro run multi-jvm tests when validating pr 
* addunidoc task via an AutoPlugin that depends on PrValidation and Unidoc autoplugins
* separate cli option logic to a case class
* remove autoplugin for root project
 2015-05-28 13:57:50 +03:00
Roland Kuhn
5dc25fbb44 add crosscompilation for 2.12.0-M1 2015-05-21 21:09:30 +02:00
Roland Kuhn
18688fc84b = #17380 fix doc comments for java8 doclint 
* actor and cluster-metrics comments
* agent/camel/cluster/osgi/persistence/remote comments
* comments in contrib/persistence-tck/multi-node/typed
 2015-05-18 12:51:36 +02:00
Patrik Nordwall
10a11e415e !cls #13711 Move cluster sharding 2015-05-11 20:07:22 +02:00
Patrik Nordwall
fb72214d99 !clt #13711 Move cluster tools from contrib 
* new module akka-cluster-tools containing
  cluster singleton, distributed pub-sub, and cluster client
 2015-05-11 20:07:21 +02:00
Patrik Nordwall
c991d5f1d1 =str #17200 Stop shard region when MemberRemoved 
Two issues:

1) ShardRegion actor must stop itself when the node is shutting down,
   ie. when receiving MemberRemoved(selfAddress)
2) ShardCoordinator must not persist anything when the node is shutting
   down. MemberRemoved of other shard regions will trigger Terminated,
   which must not be persisted, because then the next coordinator will
   replay those events and end up in wrong state. This is a problem
   announced itself when using leaving as illustrated in the new test.

To solve the second issue I have added a new ClusterShuttingDown event
that is published before the MemberRemoved events. Note that Terminated
is triggered by MemberRemoved.

(cherry picked from commit 1b272c72597beece9d93f0054f4b58e3d25f9ae2)
 2015-04-22 12:46:30 +02:00
Patrik Nordwall
ca526232e1 =con #17169 Add missing barrier in ReliableProxySpec 2015-04-15 14:17:49 +02:00
Benjamin Poserow
8d6b899be8 +con #16141 Add GetTopics message to DistributedPubSubMediator providing list of topics 2015-04-15 11:29:28 +02:00
Roland Kuhn
2bb208297d Merge pull request #17154 from akka/wip-13869-cluster-singleton-speedup-patriknw 
=con #13869 Speedup startup of Cluster singleton
 2015-04-14 21:24:45 +02:00
Patrik Nordwall
2ecfa42801 =con #13869 Speedup startup of Cluster singleton 
* avoid the hand-over/take-over attempts when starting the
  ClusterSingletonManager for the normal clase when the cluster is
  in a good shape, i.e. no exiting member that might run previous
  singleton instance
 2015-04-14 16:21:25 +02:00
Patrik Nordwall
a12bca1b15 =doc Clarify cluster singleton role 2015-04-13 10:07:14 +02:00
Patrik Nordwall
a460a7a8ff =con #15817 add missing cancel of scheduled sharding task 2015-04-01 15:04:39 +02:00
Patrik Nordwall
d79fe79802 Merge pull request #17078 from bantonsson/wip-16946-HTFU-ReliableProxyMultiJvmSpec-ban 
=con #16946 Make ReliableProxyMultiJvmSpec not reuse proxy actor name
 2015-04-01 14:21:47 +02:00
Björn Antonsson
cdb7eee0c3 =con #16946 Make ReliableProxyMultiJvmSpec not reuse actor name 2015-03-26 12:04:00 +01:00
drewhk
d9db42b757 Merge pull request #16884 from drewhk/wip-16505-forwardport-drewhk 
=rem #16505: Do not publish AddressTerminated (missing fwd port)
 2015-03-25 14:44:15 +01:00
Endre Sándor Varga
dffd7b0bbd fixed ClusterShardingSpec 2015-03-25 13:09:04 +01:00
Patrik Nordwall
7aa9fe25f2 Merge pull request #17024 from carrot-garden/persistence-leveldb-dependency 
!per #15884 Make LevelDB an optional dependency
 2015-03-25 09:07:55 +01:00
Andrei Pozolotin
5c5e07ec4e !per #15884 Make LevelDB an optional dependency 2015-03-24 13:58:09 -05:00
Julian Tescher
00f6a58e7c Changes all occurances of Typesafe copyright to extend to 2015 2015-03-10 14:12:19 -07:00
Patrik Nordwall
30df518421 =tes Use ConversionCheckedTripleEquals 2015-03-10 08:17:03 +01:00
Andrei Pozolotin
6332f888ce +all #16632 Make serialization identifiers configurable in reference.conf 2015-03-05 11:55:05 -06:00
Roland Kuhn
a029a90502 fix warnings in contrib, docs, osgi, persistence and slf4j 2015-02-06 18:45:58 +01:00
Katsunori Kanda
55e41d6d56 =doc fix typo 2014-12-15 01:37:57 +09:00
Patrik Nordwall
21fcc28629 =con #16358 Harden ClusterShardingFailureSpec 2014-11-21 11:39:18 +01:00
Andrei Pozolotin
d83acb92c3 = akka-*: full name space for loggers - resolve #16138 
reflect logger name changes in the migration guide

fix typo in migration guide

fix typo in migration guide (xml)
 2014-11-18 09:17:07 -06:00
Patrik Nordwall
c183989ea2 Merge pull request #16136 from rmarsch/entryRoleOverride-#16123 
ClusterSharding: Expanded cluster roles support
 2014-11-05 07:31:25 +01:00
rmarsch
aa59bfdcf6 !con #16123 Expand cluster roles support in ClusterSharding 
Allow a roleOverride: Option[String] to be used when starting ClusterSharding for a given entry type. This will allow role defined clusters of ClusterSharding for entry types instead of requiring the role configuration to be all or nothing across all entry types.
 2014-11-03 11:23:07 -05:00
Patrik Nordwall
ffe2992917 =con #15788 Harden ClusterShardingSpec 2014-11-03 08:09:32 +01:00