Commit graph

23734 commits

Author SHA1 Message Date
Christopher Batey
b9f02aba0c Deprecation removal hunt (#27250) 2019-07-05 13:16:51 +02:00
Patrik Nordwall
3f4179c316 Remove additional-serialization-bindings, #26684
This should be safe for a rolling update between Akka 2.5.x and 2.6.0
also if additional-bindings were disabled in 2.5.x because:
* if 2.6.0 sends one of those the serializer (akka-misc) exists in 2.5.x
  so deserialization will work via the serializerId
* if 2.5.x sends one of those with java serialization it can be
  deserialized in 2.6.0 since the java serializer exists
  (disabling java serialization by default is another ticket)

* historical problems with serialization of remote Deploy messages
  in Akka 2.4.x should be gone now
2019-07-05 13:12:36 +02:00
Patrik Nordwall
72730036be Serialization of case object with Jackson, #27283
* the serializer must treat case objects specially since
  the way the class is loaded is different, and Jackson
  object mapper shouldn't be involved in fromBinary
2019-07-05 11:38:28 +02:00
Christopher Batey
2db03309ce
Akka Persistence instrumentation improvements (#26946) (#27280) 2019-07-05 10:06:07 +01:00
Christopher Batey
7c151a4279 Pattern for responding to a sharded actor (#27077) 2019-07-05 10:29:23 +02:00
Christopher Batey
1dfe55fcc3 Typed Stash: Create via factory method on Behaviors (#27200)
* changing to trait in javadsl
2019-07-05 10:28:07 +02:00
Patrik Nordwall
72680e93bf EventSeq in Typed EventAdapter (#27130)
EventSeq in Typed EventAdapter, refs #26909
2019-07-05 09:46:10 +02:00
Patrik Nordwall
daac56cc40 use Scala 2.13 for last step in release script 2019-07-05 09:37:06 +02:00
Patrik Nordwall
16f2009786 fix two log messages related to use-unsafe-remote-features-without-cluster (#27241)
* one was always logged at startup when using cluster provider
* the other was logged (at debug) each time an ordinary local actor was started
2019-07-05 08:11:33 +01:00
Xin Yin
44dcfe057a Fix an issue of prolonged delay in the Delay stage #26470 2019-07-05 09:07:16 +02:00
Patrik Nordwall
51041b1faf
Merge pull request #27081 from dwijnand/make-EntityRef-and-EntityTypeKey-contravariant
Make EntityRef & EntityTypeKey contravariant
2019-07-05 09:05:49 +02:00
Patrik Nordwall
ae6bf2d4bd Style: Update HelloWorld sample to OO style for Java, #22805
* and use create/apply behavior factory method naming
2019-07-05 08:30:48 +02:00
Patrik Nordwall
ff76211f4d
Merge pull request #27257 from hepin1989/nullMsg
Add sender to the exception message when the message sent is null.
2019-07-05 08:27:14 +02:00
Johan Andrén
beb35bf12d
First step in restructuring the docs for 2.6 #26487 2019-07-05 08:21:38 +02:00
Johan Andrén
5fe12a3e9d
Subscription timeouts not working #19980 2019-07-05 08:19:46 +02:00
Christopher Batey
62f639e054 Replace ActorPublishers in leveldb with stages #26187 2019-07-04 16:57:17 +02:00
Christopher Batey
7c94367d13
Cluster heartbeat timings (#26757)
* Serializer for Heartbeat and HeartbeatRsp that includes sendTime and sequenceNr

A future release will be required to use the serialiser once there has
been a release with this PR so that old nodes can deserialise the new
message.

* Cross DC heartbeating sequenceNr and sendTime
2019-07-04 14:21:24 +01:00
Patrik Nordwall
f9d76aa030
Log Dropped from DeadLetterListener, #26432 (#27160)
* Log Dropped from DeadLetterListener, #26432

* Move Dropped from akka-actor-typed to akka-actor
* Use it in Artery
* Use in right way from GroupRouter, not via deadLetters
* Remove "without sender" in log message from DeadLetterListener,
  since there is no sender in Typed
* mima filter
* add sender to Dropped
2019-07-04 14:52:42 +02:00
Patrik Nordwall
7a16403f1b
Merge pull request #27246 from 2m/wip-expect-no-message-sub-2m
Add expectNoMessage to subscriber probe
2019-07-04 14:49:14 +02:00
hepin1989
a11d2b6b3a Add sender to the exception message when the message sent is null. 2019-07-04 19:05:36 +08:00
Martynas Mickevičius
f75f1943a2
Add expectNoMessage to subscriber probe 2019-07-04 13:52:53 +03:00
Johan Andrén
7c6d3b818a FlowDelay with EmitEarly caused a NPE (#27170) 2019-07-04 11:06:24 +02:00
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