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

23052 commits

This branch
This branch
All branches
Author SHA1 Message Date
Josep Prat
a31964475e Add forgotten expectNoMessage method in StreamTestKit (#26070) 
* Add forgotten `expectNoMessage` method in StreamTestKit

As discovered during https://github.com/akka/akka-http/pull/2292#discussion_r239473817 the parameterless version of `expectNoMessage` in StreamTestKit is missing.
 2018-12-12 10:25:29 +01:00
Dale Wijnand
74ee90d52d Introduce Behavior#unsafeCast (asInstanceOf alt) (#26093) 
* Remove some unnecessary casts in WithMdcBehaviorInterceptor

* Reuse Behavior.same & Behavior.unhandled

* Introduce Behavior#unsafeCast (asInstanceOf alt)

Also introduce StoppedBehavior#cast, as a local, safe alternative.
 2018-12-11 15:56:01 +01:00
Patrik Nordwall
e34a4859e5
Merge pull request #26106 from renatocaval/load-discovery-scaladoc 
updated scaladoc for loadServiceDiscovery
 2018-12-11 15:48:00 +01:00
Renato Cavalcanti
7310992583 updated scaladoc for loadServiceDiscovery 2018-12-11 14:44:03 +01:00
Patrik Nordwall
ed78c183dc
Merge pull request #26096 from akka/fixLagomLink 
Fix link to lagom
 2018-12-11 11:38:23 +01:00
Patrik Nordwall
229db51eb4 Cleanup validNodeForGossip (#25965) 
The intended behavior is:
* don't gossip to node marked as unreachable by self (heartbeat
  messages are not getting through so no point in trying to gossip).
* gossip is allowed to nodes marked as unreachable by others

This doesn't change anything from how it worked before, but I think the
original intention before the multi-dc changes was to not gossip to
unreachable at all no matter who marked them.
 2018-12-10 17:18:53 +01:00
Arnout Engelen
b40d28b885
Fix link to lagom 2018-12-10 15:52:38 +01:00
balteo
24ff2b80e7 Fix broken link to lagom framework (#25844) 2018-12-10 15:51:18 +01:00
Patrik Nordwall
44c618cce0
Merge pull request #26075 from chbatey/2519mima 
update mima latet version for 2.5.19
 2018-12-10 13:59:17 +01:00
Patrik Nordwall
20f7acb34d
Merge pull request #26091 from dwijnand/reuse-scala.reflect.classTag-and-ClassTag.Nothing 
Reuse scala.reflect.classTag & ClassTag.Nothing
 2018-12-10 13:46:26 +01:00
Patrik Nordwall
3916ef382e
Merge pull request #26092 from dwijnand/give-BackoffSupervisor-an-O-outer-msg-type-param 
Give BackoffSupervisor an "O" outer msg type param
 2018-12-10 13:42:52 +01:00
Patrik Nordwall
8fd4cb5298
Merge pull request #26094 from dwijnand/use-OptionVal-over-null-in-typed-TimerSchedulerImpl/TimerInterceptor 
Use OptionVal over null in typed TimerSchedulerImpl/TimerInterceptor
 2018-12-10 13:30:49 +01:00
Aleksei Molokovskikh
4fe5b1cb59 fixed deprecated method in getting started guide (#26083) 2018-12-10 10:45:24 +00:00
Dale Wijnand
9f102813b6 Remove typed.ActorRef#sorry/sorryForNothing (#26090) 
These were unsafe (despite the lying commnet) & unused.
 2018-12-10 10:44:37 +00:00
Dale Wijnand
384c92dc89
Use OptionVal over null in typed TimerSchedulerImpl/TimerInterceptor 2018-12-09 22:57:05 +00:00
Dale Wijnand
a1ed1d3215
Give BackoffSupervisor an "O" outer msg type param 
This begins to reintroduce some typesafety into BackoffSupervisor, using
the necessary cast internally where this isn't honoured.
 2018-12-09 22:07:46 +00:00
Dale Wijnand
fc4b1238f4
Reuse scala.reflect.classTag & ClassTag.Nothing 2018-12-09 22:07:26 +00:00
Christopher Batey
58df72330d update mima latet version for 2.5.19 2018-12-07 16:13:11 +00:00
kerr
a2590db3f5 Add description about default method parameters. 2018-12-07 18:28:03 +08:00
Patrik Nordwall
712b72f649
Merge pull request #26069 from akka/wip-PatternCS-followup-patriknw 
doc and test follow up of PatternCS, #26000
 2018-12-06 21:26:59 +01:00
Christopher Batey
e1dc8dcb4e Dont run DnsDiscoverySpec if docker not available (#26071) 
* Dont run DnsDiscoverySpec if docker not available

Fixes #26062
 2018-12-06 21:24:53 +01:00
Patrik Nordwall
bb3a40010c another remove redundant yet, from PR #26049 2018-12-06 20:18:23 +01:00
Christopher Batey
66fa541118
Make exception in Terminated explicit it is just for child termination (#25992) 
* Remove exception from typed Terminated

This currently only works for direct child actors and breaks when using
typed supervision.

It could be re-introduced by supervision returning a new special
behavior that the actor adaper for failed with an exception.

* Try out keeping the terminated and adding a ChildTerminated subclass of Terminated

Some tests need updated will fix those if we decide this is better

* Fix duplicate logging + make it Terminated + ChildFailed
 2018-12-06 17:49:25 +00:00
Christopher Batey
da71e2044e
Allign typed singleton with typed sharding (#26013) 
* Allign typed singleton with typed sharding

* Singleton class for setting proerties
* Make stop message optional

Closes #25670
 2018-12-06 16:26:38 +00:00
Patrik Nordwall
1f4812d8a5 doc and test follow up of PatternCS, #26000 2018-12-06 17:18:47 +01:00
Patrik Nordwall
7439893f12
Merge pull request #26049 from robertgol/patch-1 
remove redundant yet
 2018-12-06 15:54:08 +01:00
Patrik Nordwall
cf95381df7
Merge pull request #26051 from hepin1989/internal 
Change InternalMessage to be private[akka].
 2018-12-06 15:52:01 +01:00
Patrik Nordwall
b04accefa0
Merge pull request #25833 from akka/wip-getting-started-typed-patriknw 
Translate Getting Started Guide to Typed, #25998
 2018-12-06 15:45:17 +01:00
kerr
b7f3cbef94 Merge PatternsCS to Patterns (#26008) 
* !act Move some Java API methods from PatternsCS to Patterns.

* Deprecate PatternCS and in favor of Patterns.
 2018-12-06 15:40:43 +01:00
Patrik Nordwall
4f100a1f1e
Merge pull request #26058 from akka/wip-discovery-version-patriknw 
add akka-discovery to version check
 2018-12-06 15:39:09 +01:00
Patrik Nordwall
918843d54e
Merge pull request #26050 from akka/wip-25985-unidoc-patriknw 
only unidoc for Scala 2.12, #25985
 2018-12-06 15:38:11 +01:00
Patrik Nordwall
76276e6504 Translate Getting Started Guide to Typed, #25998 
* convert example code
* update doc content
* update diagrams
* rewrite parental supervison part
 2018-12-06 15:29:39 +01:00
Patrik Nordwall
4966d5262e fix type bounds of expectMessageClass in javadsl in Typed 2018-12-06 14:52:38 +01:00
Patrik Nordwall
0d0a0e8018 fix javadsl awaitAssert in Typed, #25903 
* returning null would result in retries until "timeout value is negative"
* use same implementation as in untyped
* real test
 2018-12-06 14:52:38 +01:00
Patrik Nordwall
e1a0a1fa3f Save EntityStarted when StartEntity requested via remembered entities (for validation) (#26061) 
* Save EntityStarted when StartEntity requested via remembered entities
 2018-12-06 13:49:47 +00:00
Patrik Nordwall
850a10443b support stop of TestProbe 2018-12-06 14:48:52 +01:00
Patrik Nordwall
7bce22f2ea revert to sbt 1.2.6, because unidoc issue 
* the update to sbt 1.2.7 in commit 6ba4c341f5
  broke unidoc (javadoc)
 2018-12-06 12:48:08 +01:00
Patrik Nordwall
4742a23e9e only unidoc for Scala 2.12, #25985 
* otherwise the docs built with 2.11 will be published for release,
  since the 2.11 build is last
 2018-12-06 12:48:01 +01:00
Patrik Nordwall
4f0d793f16 add akka-discovery to version check 2018-12-06 12:32:29 +01:00
Christopher Batey
e5c1fc02a9
Support ClusterSharding passivation in BackoffSupervisor (#25933) 
* Specific final stop message predicate instead of arbitrary action
 2018-12-06 10:10:37 +00:00
hepin1989
252f3432c5 Change InternalMessage to be private[akka]. 2018-12-06 04:08:28 +08:00
Nicolas Vollmar
8b8c7355bf Adding loglevel for overflow strategy #25949 (#25976) 
* Adding loglevel for overflow strategy (#25949)

* Simplifying overflow strategy api (#25949)

* Adding overflow strategy check for backpressu (#25949)

* Adding log statements to all stages with overflow strategy (#25949)

* Adding excludes for internal api changes (#25949)

* Adding internal api annotations (#25949)

* Adding log source overrides for better logger names (#25949)

* Moving mima excludes for 2.5.18 (#25949)
 2018-12-05 13:31:43 +00:00
Christopher Batey
c5c2f951db Dns discovery custom resolver (#25937) 
* Import service discovery from akka-management

* Rename extension to Discovery to go with akka-discovery name
* Rename interafce to ServiceDisovery
* Import config, aggregate and dns
* Discovery documentation
* Load isolated async-dns if not configured as default
* OSGi for discovery
* Remove warning for not using in production
* Fail if old akka management on classpath
* Only allow async dns to be loaded as an additional resolver
* Use method in all of service discovery, not mechanism
* Mima filter
* Add discovery to aggregate
* Set discovery mima versions
* DnsDiscoverySpec: Only run docker test if docker available
 2018-12-05 14:01:24 +01:00
Patrik Nordwall
bca269d684
Merge pull request #25989 from chbatey/graal 
Add Graal recommendation to contributing guide
 2018-12-05 13:52:48 +01:00
Patrik Nordwall
ab7591b809
Merge pull request #26048 from akka/wip-26036 
Rename PersistentBehavior (#25721) (for validation)
 2018-12-05 13:43:19 +01:00
Robert Golusiński
2b7ba8f9f1
remove redundant yet 2018-12-05 13:19:27 +01:00
Christopher Batey
69c58b3725
Harden AsyncDnsResolverIntegrationSpec (#25908) 
* Harden AsyncDnsIntegrationSpec
* Ensure that the port is available on TCP and UDP
* Don't listen on ipv6 (fails on jenkins sometimes)
 2018-12-05 11:35:10 +00:00
Helena Edelson
dbfe6f38c7 Rename PersistentBehavior (#25721) 
Migrated InternalProtocol with least refactor changes, in the end.
 2018-12-05 12:05:59 +01:00
Arnout Engelen
7afd847758 fix akka-cluster-sharding-typed/test:compile (#26046) 
Weird that CI didn't catch this
 2018-12-05 10:30:38 +00:00
Christopher Batey
bf714dd72a BackoffSupervisorSpec: Fix race of terminated messages (#25947) 2018-12-05 11:25:50 +01:00