Commit graph

22730 commits

Author SHA1 Message Date
Roman Filonenko
d0feb5f28e fix non-@ref tag in serialization (#25900) (#25901) 2018-11-13 10:06:49 +01:00
Dale Wijnand
17a6a470ee Change untyped EventStream's Event type to Any (#25897)
Having it be AnyRef just makes it harder to use with a generic type,
because now instead of any type `T` it has to be a type `T <: AnyRef`.

There's no benefit in having it as AnyRef over Any.
2018-11-13 07:57:06 +00:00
Christopher Hunt
86884133ed Avoid memory being retained for groupBy #24758
This commit avoids memory being retained for groupBy. Prior to the commit, closedSubstreams could grow unbounded. This commit includes the size of closedSubstreams when considering to take on a new substream, while retaining the semantics described by its Flow API.
2018-11-09 18:28:44 +01:00
kerr
e847ce016a +act add getEventStream to ActorSystem #25870 2018-11-09 12:29:05 +01:00
Johan Andrén
f66ee1cbe8
Handle lost typed receptionist removals #24887
Keep track of removed actors and re-remove them when ORMultiMap conflict has reintroduced them
2018-11-09 10:58:18 +01:00
Patrik Nordwall
ea80ce10fa
Merge pull request #25758 from akka/wip-25485-auction-sample-patriknw
AuctionEntity example in Java, #25485
2018-11-09 10:40:14 +01:00
Patrik Nordwall
42adfd781c
Merge pull request #25801 from akka/wip-25794-ClusterShardingSpec-patriknw
Hardening of typed./ClusterShardingSpec, #25794
2018-11-09 09:53:14 +01:00
Patrik Nordwall
b1b959df50 AuctionEntity example in Java, #25485 2018-11-09 09:48:26 +01:00
Patrik Nordwall
90bc4cfa3e
Improvements of singleton leaving scenario, #25639 (#25710)
* Testing of singleton leaving
* gossip optimization, exiting change to two oldest per role
* hardening ClusterSingletonManagerIsStuck restart, increase ClusterSingletonManagerIsStuck
2018-11-09 09:42:48 +01:00
Patrik Nordwall
f6dbb91175 update latestPatchOf25 (#25892) 2018-11-09 09:16:33 +01:00
Philippus Baalman
90bf989630 Replace scalactic deprecations (#25886) 2018-11-09 09:07:21 +01:00
Christopher Batey
847a7c1afd Add warning about nsswitch to dns docs (#25889) 2018-11-09 09:06:17 +01:00
Dale Wijnand
3744baf82f Make OpenAccount#applyEvent match exhaustive (#25890) 2018-11-09 09:05:23 +01:00
Patrik Nordwall
70176341d9
Merge pull request #25847 from chbatey/dns-warn
Warn about async-dns lack of support for search domains
2018-11-07 12:36:00 +01:00
Arnout Engelen
14d9b845c4
Clarify CrossJava will be on-par in sbt 1.3.0 (#25876) 2018-11-07 09:48:30 +01:00
Martynas Mickevičius
6cbba51f94 Update to the latest Akka Paradox that adds icons to goto source links (#25881) 2018-11-07 09:19:02 +01:00
Patrik Nordwall
784e300343
Merge pull request #25818 from akka/wip-25642-auto-sharding-stop-msg-patriknw
Make the stop message in sharding optional, #25642
2018-11-06 21:31:52 +01:00
Patrik Nordwall
4d115f19a6 rename ClusterSharding start to init, #25711 (#25867)
* rename ClusterSharding start to init, #25711

* fix test
2018-11-06 19:43:55 +01:00
Patrik Nordwall
9c1153b1a6 Make the stop message in sharding optional, #25642
* It's mostly technical concern that is blurring the business logic in the entity
* Async interactions before stopping is often not needed
* Implemented with an internal PoisonPill signal that is added by sharding,
* Persistent actors handle PoisonPill and run side effects after persist
  and process stashed messages before stopping.

* remove unecessary stop messages

* reference docs
2018-11-06 19:43:55 +01:00
Johan Andrén
133c41375f Automatic passivation for typed sharding, #25512 2018-11-06 19:15:23 +01:00
Patrik Nordwall
3ccc67b3d6
Merge pull request #25812 from akka/wip-25706-thenRun-patriknw
align Effect API between scaladsl and javadsl, #25706
2018-11-06 16:09:39 +01:00
Patrik Nordwall
a948f5572b align Effect API between scaladsl and javadsl, #25706
scaladsl:
* stop => stop()
* andThenStop() => thenStop()

javadsl:
* andThen => thenRun
2018-11-06 15:02:08 +01:00
Dale Wijnand
934a28ba5c Rename ActorContext#schedule with scheduleOnce (#25869) 2018-11-06 11:05:43 +01:00
Patrik Nordwall
ee9b0e6d24
Merge pull request #25868 from dwijnand/unleash-OptionVal
Allow OptionVal to hold boxed primitives
2018-11-05 19:56:53 +01:00
Dale Wijnand
ee04105a5e
Allow OptionVal to hold boxed primitives
Previously OptionVal was restricted to types that have Null as their
bottom type, that is reference types (that extend AnyRef/Object), rather
than also allowing primitives (that extend AnyVal).

By removing this restrictions any type is a valid type argument.

The effect this will have is that primitives will be box, because we
need a way to represent the None case (using the null value).
2018-11-05 15:28:42 +00:00
Tim Moore
8247c8df50 Fix typo in lookup of ResolverConfiguration (#25826)
* Fix typo in lookup of ResolverConfiguration

* Set a longer timeout for launching bind
2018-11-05 15:05:16 +01:00
Dale Wijnand
9941f7d800 Consistently bind ActorContext to 'context' in the docs (#25852)
* Consistently bind ActorContext to 'ctx' in the docs

... over the lesser uses 'context':

    $ rg 'Behavior[s]?.setup' akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala akka-actor-typed-tests/ akka-actor-testkit-typed/ | rg ctx | wc -l
          59
    $ rg 'Behavior[s]?.setup' akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala akka-actor-typed-tests/ akka-actor-testkit-typed/ | rg context | wc -l
           8
    $ rg 'Behavior[s]?.receive' akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala akka-actor-typed-tests/ akka-actor-testkit-typed/ | rg ctx | wc -l
          66
    $ rg 'Behavior[s]?.receive' akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala akka-actor-typed-tests/ akka-actor-testkit-typed/ | rg context | wc -l
           5

* Fix "variable ctx is already defined" warnings

* Replace ctx with context, in docs & doc snippets

    fastmod '\bctx\b' 'context' \
        akka-docs/src/main/paradox/typed
        akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala \
        akka-actor-typed-tests/ \
        akka-actor-testkit-typed/ \

* Replace msg with message, in docs & doc snippets

    fastmod '\bmsg\b' 'message' \
        akka-docs/src/test/scala/docs/actor/TypedActorDocSpec.scala \
        akka-actor-typed-tests/ \
        akka-actor-testkit-typed/
        akka-docs/src/main/paradox/typed/

* Fix code alignment
2018-11-05 13:53:18 +00:00
Arnout Engelen
7bbac405c3 Widen timeout waiting for sharding to initialize (#25752) (#25856) 2018-11-05 14:15:49 +01:00
Dale Wijnand
91101d996c Mini cleanup to stream.ActorMaterializer (#25866)
Do it once, instead of in all 4 call sites.
2018-11-05 14:10:54 +01:00
Arnout Engelen
079aa46733 Introduce 'MemberDowned' member event (#25854)
* Introduce 'MemberDowned' member event

Compatiblity note: MemberEvent is a sealed trait, so it is debatable whether
it is acceptable to introduce a new member.

* Be more conservative (more like leaving), add test
2018-11-05 10:03:06 +00:00
Dale Wijnand
cb9b35d8ee Favour Behaviors.receiveMessage in the docs (#25853)
... over Behaviors.receive, but not using the ActorContext binding.
2018-11-05 09:57:36 +00:00
Dale Wijnand
6a04731971 Dilation cleanups (#25861)
* Avoid calling asInstanceOf in dilated

* Fix the rounding in dilated for Java

* Delegate Java dilated to Scala dilated

* Import scala.concurrent.duration.Duration
2018-11-05 09:55:40 +00:00
Christopher Batey
f51c8d8506 Read port/weight/priority as unsigned shorts for SRVRecords (#25842)
* Read port/weight/priority as unsigned shorts for SRVRecords

* Delete writing code for resource records. Isn't used/tested.

* Mima and review feedback
2018-11-05 09:41:47 +01:00
Ignasi Marimon-Clos
48cf769ee7 Fix: DNS TTL uses seconds while caching usese millis (#25848)
* Fix: DNS TTL uses seconds while caching uses millis
* Consistently rename ttl vals in companion objects. Add mima filters.
* Rename fields to ttlInZzzz format
2018-11-02 15:44:33 +01:00
Dale Wijnand
87a033efff @DoNotInherit typed.ActorRef (#25851) 2018-11-02 11:46:20 +00:00
Christopher Batey
e242927d76 Warn about async-dns lack of support for search domains 2018-11-01 09:55:47 +00:00
Johan Andrén
6329a7b77e
Ignore vendor when selecting JVMs #25835 2018-10-30 10:51:30 +01:00
kerr
fafc59b19d update headers to regular comment (#25807) 2018-10-29 05:19:37 -04:00
mohammad mehdi
ba996f8c5f example for some sink operators #25468
Examples for takeLast, last and lastOption operators
2018-10-25 09:40:36 -04:00
Saleh Khazaei
91b0c387be Add examples for Fan-in operators #25468 2018-10-25 09:37:48 -04:00
Jonas Chapuis
b8a9f8b6d7 Zip/Unzip support up to 22 ports (#25742)
* Zip/Unzip support up to 22 inputs/outputs respectively
2018-10-24 09:38:07 -04:00
Patrik Nordwall
4479046d1e fix cluster routing docs (#25810)
* broke when it was moved to separate page
2018-10-24 08:13:43 -04:00
Johannes Rudolph
655bef2e71 Fix typo in reference.conf (#25821) 2018-10-24 07:42:03 -04:00
Patrik Nordwall
751a67ef42
Merge pull request #25659 from akka/shardingErrorMessage
Add troubleshooting hint to logging
2018-10-18 15:07:12 +02:00
Dolly Gyanchandani
e26a90f340 Create typed ActorMaterializer from ActorContext, ##25536
* Create typed ActorMaterializer from ActorContext to bind stream's lifecycle with an actor's lifecycle

* Add Java API for creating typed ActorMaterializer from ActorContext
2018-10-18 15:03:27 +02:00
Patrik Nordwall
abb3429bc8
Merge pull request #25804 from akka/wip-25750-AbstractBehavior-patriknw
Rename MutableBehavior to AbstractBehavior, #25750
2018-10-18 13:16:48 +02:00
Patrik Nordwall
1d4fb852d0
Merge pull request #25697 from akka/wip-PersistentEntity-patriknw
PersistentEntity to glue together Sharding and PersistentBehavior better
2018-10-18 13:11:18 +02:00
Patrik Nordwall
2672bd7a95 PersistentEntity to glue together Sharding and PersistentBehavior better
* Makes the combination more visable
* You don't have to worry about the persistenceId, only EntityTypeKey and entityId
* The glue is stronger in the javadsl because of two reasons
  * Couldn't realisticly create a PersistentEntity class extending PersistenBehavior (which
    contains all the optional parameters and functions) since that would duplicate too much.
  * The ActorContext would be needed in the ShardedEntityContext parameter and because of the
    additional M type parameters the type inference breaks down when using the factory. Would
    require specifying the type of the ShardedEntityContex[M] parameter. That problem doesn't
    seem to exist in Java.

renamed:
s/ShardedEntityContext/EntityContext/
s/ShardedEntity/Entity/
2018-10-18 11:47:51 +02:00
Patrik Nordwall
bed17cc172
null as empty state, in javadsl, #25768 2018-10-18 11:38:27 +02:00
Patrik Nordwall
1691961a10
AccountExample in Scala in a few flavors, #25485
* AccountExample in Scala in a few flavors
* include Account examples in reference docs
* cleanup BlogPost example
* include reply doc snippets
2018-10-18 11:37:06 +02:00