Commit graph

23661 commits

Author SHA1 Message Date
Christopher Batey
139d9a3c0c Remove ApiMayChange from typed testkit (#27096)
* Remove ApiMayChange from typed testkit

* Don't disable mima plugin to highlight times we break bin cmompat

Refs #26897

* Add api may change to test inbox and behavior test kit
2019-07-04 11:03:27 +02:00
Patrik Nordwall
310b861d69
Merge pull request #27178 from akka/wip-typed-testkit-docs-patriknw
move synchronous behavior testing docs
2019-07-04 11:01:15 +02:00
Patrik Nordwall
76c3271575
Support same dispatcher as parent in Typed, #27123 (#27127)
* Support same dispatcher as parent in Typed, #27123

* remove apply in internal DispatcherDefault and DispatcherSameAsParent
2019-07-04 11:00:04 +02:00
Patrik Nordwall
d88db078ad
Merge pull request #27097 from chbatey/flow-context-api-may-change
Remove API may change for flow with context
2019-07-04 10:58:25 +02:00
Patrik Nordwall
75e52ba886 Allow widen to be used with EventSourcedBehavior, #25887 (#27251)
* by using a plain BehaviorInterceptor instead of widen
  inside EventSourcedBehaviorImpl
2019-07-03 09:46:37 +02:00
Patrik Nordwall
d2cae7d345 Remove Behavior.orElse, #26867 (#27252)
* kept part of OrElseSpec to illustrate composition with
  functions or partial functions
* added an experiment with and interceptor that
  delegates to behaviors
2019-07-03 09:23:05 +02:00
Patrik Nordwall
64fa2979ea
ClassTag in BehaviorInterceptor, #25887 (#27148)
* Always be explicit about what message types an interceptor can handle, to avoid
  ClassCastException if another message type is passing. That may happen when
  the inner behavior understands other messages than it says in it's declared
  behavior type by using narrow. EventSourcedBehaviorImpl is an example.
* Minimized failing tests
* Supervision interceptor is of type Any since failures of all messages must be
  handled
* Changed PoisonPillInterceptor to only intercept signals
* rename type params to Outer and Inner
* separate BehaviorSignalInterceptor
  * which only intercepts signals and messages bypass, e.g. PoisonPillInterceptor
  * also made aroundSignal optional to override in BehaviorInterceptor
* Add test for interceptors combined with EventSourcedBehavior
* ClassTag not needed for LogMessagesInterceptor
  * since it can handle Any
* test supervision of different message type
* clarify low level
* docs for interceptMessageClass param and ClassTag
* remove O type parameter in supervision
* remove extra setup for RestartSupervisor, already factory
* mention in migration guide
2019-07-02 17:49:48 +02:00
Arnout Engelen
a36ec1260d Move a couple of Akka Streams examples to their own files (#26703) 2019-07-02 16:54:53 +02:00
Patrik Nordwall
a3ae0787ba
Merge pull request #27167 from chbatey/regular-rebalance-log
Log rebalance progress at INFO per rebalance info
2019-07-02 14:02:42 +02:00
Patrik Nordwall
e3dc7b16b3
Merge pull request #27005 from akka/documentSourceApply
Merge Source.apply and Source.from docs
2019-07-02 13:43:00 +02:00
Patrik Nordwall
8db73abd33
Merge pull request #27209 from akka/wip-sys-log-patriknw
better logger class for typed.ActorSystem
2019-07-02 12:41:39 +02:00
Christopher Batey
200b07e534
Re-write InputStreamSource as GraphStage (#26811)
* Re-write InputStreamPublisher as a GraphStage
* Deprecate IOResult.failure and introduce IOOperationIncompleteException

After some dicussion with @johanandren, @raboof and @2m about the
confusion of the materialised value of the IO streams to complete
even if there is an exception (with the exception in the IOResult)
this now changes it to:

* Deprecate failure in IOResult so it is always set to Success(Done)
* Stop using AbrubtIOTerminationException as the inner IOResult also
contains an exception causing confusion
2019-07-02 10:46:16 +01:00
Patrik Nordwall
0adea81da1 move synchronous behavior testing docs
* readers tend to try what is at the top of the page
  and given the limitations of BehaviorTestKit we
  should show the full featured asyncronous TestKit first
* mention test framework integration earlier
* better example in the test framework section
2019-07-01 13:40:38 +02:00
Christopher Batey
cfed2512d7
update modules list for akka enhancements (#27229)
* update modules list for akka enhancements
2019-07-01 07:57:50 +01:00
Ignasi Marimon-Clos
7766e922e0 Fixes same typo mutiple times (#27236) 2019-06-28 14:48:55 +01:00
Johan Andrén
4af031c9a5
ActorHierarchyExperiments: Send a start message to the first actor (#27204) 2019-06-27 20:54:09 +01:00
Patrik Nordwall
b53469500b
Reduce boilerplate for interaction with Typed Replicator #27116 (#27118)
* Reduce boilerplate for interaction with Typed Replicator #27116

* By introducing a message adapter "helper" that is specific the Replicator
* Specific methods for askUpdate, askGet and askDelete, subscribe, unsubscribe

* add thread safetey warnings

* DistributedData.withReplicatorMessageAdapter for creating the ReplicatorMessageAdapter
2019-06-27 16:56:21 +01:00
Stefan Ganzer
e59819a4cd ActorHierarchyExperiments: Send a start message to the first actor (#27204)
* Send a `start` message to the first actor

Otherwise, only the actor system is started, but none of the actors.

* Send a `start` message to the first actor

Otherwise, only the actor system is started, but none of the actors.
2019-06-27 16:17:36 +01:00
Christopher Batey
9c0cece7de Clarify remembered entities limit is for active entities (#27221) 2019-06-27 16:07:34 +01:00
Arnout Engelen
d758e746d1
Fix paradox anchor references (#27226)
* Fix paradox anchor references

Found by https://github.com/lightbend/paradox/pull/326

* Remove duplicate anchors in paradox docs

Found by https://github.com/lightbend/paradox/pull/328
2019-06-27 16:05:24 +01:00
Helena Edelson
c636058d0d
Upgrade sbt-scoverage, sbt-scalafix and sbt-header (#27225)
Upgrade sbt-scoverage from milestone to 1.6.0, sbt-scalafix to 0.9.5 and sbt-header to 5.2.0 #27224
2019-06-27 15:58:02 +01:00
Patrik Nordwall
4e52432706 Rolling update when adding akka-cluster-typed dependency, #27191 (#27210) 2019-06-26 15:47:15 +01:00
Patrik Nordwall
50e99e08d8 Use short configurable timeout for expectNoMessage #27212 (#27213)
* Use short configurable timeout for expectNoMessage #27212

* consistent with ActorTestKit in Typed

* fix config
2019-06-26 15:35:20 +01:00
tayvs
e567272766 mapMaterializedValue implementation for withContext Flow/Source (#27201) 2019-06-25 15:57:03 +02:00
Patrik Nordwall
3052e7455c better logger class for typed.ActorSystem 2019-06-24 13:47:03 +02:00
Simon
c932582238 Update deploy.md to avoid Maven generating erroneous tags (#27199)
According to this: https://stackoverflow.com/a/56154292/3715185, adding an id to the execution configuration can help to keep Maven from generating erroneous tags in the effective pom, such as adding a `<resource>` tag to the `ManifestResourceTransformer`.
2019-06-24 13:15:05 +02:00
Helena Edelson
cc430fe4d0
Fixed test tagged as IgnoreForScala212 ran in nightly not hit in other CI jobs, just needed the new akka.remote.use-unsafe-remote-features-without-cluster = on. (#27202) 2019-06-22 08:29:03 -07:00
Pritam Kadam
759673569a Adding WatchedWith effect in akka actor typed testkit #27190 (#27195) 2019-06-21 07:59:32 -07:00
Helena Edelson
59f1a05819
Docs: make rolling restarts/upgrades/updates more prominent, easier to find #27039 (#27186) 2019-06-21 07:33:32 -07:00
Helena Edelson
25b5daa617
Akka Typed Add example of how to java getSelf for persistence typed #27061 (#27196) 2019-06-21 07:30:33 -07:00
Helena Edelson
611e32de91 Disable remote watch and remote deployment outside Cluster (#27126) 2019-06-21 14:15:36 +02:00
Patrik Nordwall
8757e35b7e Don't passivate idle for remembering entities (#27177) 2019-06-21 04:40:25 -07:00
Helena Edelson
37abbea118
Merge pull request #27174 from akka/wip-artery-port-patriknw 2019-06-20 16:12:16 -07:00
yiksanchan
a09d7e27be Fix typo (#27187) 2019-06-20 14:57:37 +02:00
Helena Edelson
eab2b96bd7
Merge pull request #27173 from akka/wip-27172-increase-fd-nodes-patriknw 2019-06-20 04:22:10 -07:00
yiksanchan
a50a06845a Fix grammar (#27185) 2019-06-20 08:18:08 +02:00
Christopher Batey
c1237a2448
Fix authors script to run with 2.13 (#27145) 2019-06-19 08:54:07 +01:00
Helena Edelson
2fbeca4a45
Merge pull request #27171 from akka/wip-27169-InitJoin-patriknw
Handle InitJoin messages correctly, #27169
2019-06-18 15:03:15 -07:00
Patrik Nordwall
f2dd10ceb9 Mention Artery port 25520 in migration guide 2019-06-18 18:40:03 +02:00
Patrik Nordwall
8752a3acdb increase monitored-by-nr-of-members config, #27172 2019-06-18 18:28:37 +02:00
Patrik Nordwall
74238f1cf2 Handle InitJoin messages correctly, #27169
* IntiJoin message changed from companion message to case class with config
  parameter when the join compat check was added. Some `case InitJoin =>` were
  not changed.
* Resulting in unhandled InitJoin and no InitJoinNack replies.
2019-06-18 17:39:22 +02:00
Christopher Batey
df7e5578bb
Revert to 0.4.* of ssl config for 2.13 (#27152)
We've released 2.5.23 for 2.13 with 0.4.0 but this changes the default
behavior. This reverts that so the first release we are binary compat
for 2.13 will be 2.5.24.

For 2.6 we can still perhaps upgrade
to 0.4.0 and document or override the new behavior.

Refs #27142
2019-06-18 15:21:26 +01:00
Dale Wijnand
de9643efa0 Simplify the definition of ActorRef#narrow (#27080) 2019-06-18 16:00:51 +02:00
Charies Gavin
d50674ab49 Doc improvements (#27166)
* cluster-metrics.md - delete duplicate dependency content
* futures.md - delete a redundant parentheses
* event-bus.md - delete redundant descriptions of event-bus
* howto.md - Set keywords in highlighted format
2019-06-18 13:34:45 +02:00
Christopher Batey
6946a04e20 Log rebalance progress at INFO per rebalance info
For cases where rebalance takes a long time due to a relatively large cluster change
e.g. when doubling number of nodes (common for 1-2, 3-6 etc) there is
little insignt into what is happening unless DEBUG logging is enabled.

This adds an INFO log per rebalance-interval (default is 10s) to show
what is in progress and which new shards are starting rebalancing.
2019-06-18 11:28:37 +01:00
Jakub Kahovec
04e83ffc7c Allow specifying a log level when logging exceptions being seen the SupervisorStrategy (#27147)
* Allow specifying a log level when logging exceptions being seen the SupervisorStrategy. #27133
* Add tests which verify Supervisor logging behaviour for provided log level
2019-06-18 12:04:44 +02:00
Christopher Batey
21c34361cd Fix error in sharding message flow description (#27161) 2019-06-18 12:01:11 +02:00
Johan Andrén
44043447d1 Some old netty config paths in tests fixed (#27159) 2019-06-18 10:20:06 +02:00
Enno
be67fb2ce5 Revise modules listing (#27146) 2019-06-17 18:28:30 +02:00
Arnout Engelen
af3ee37d6c
Option to target system JDK instead of JDK8 (#27083)
Inspired by the proposal by @nvollmar in 0940dfc
2019-06-17 16:55:54 +02:00