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

22735 commits

This branch
This branch
All branches
Author SHA1 Message Date
Arnout Engelen
1c8577b107 Update issue templates (#25912) 
* Update issue templates

To perhaps make it clearer that https://discuss.akka.io is the place for questions?

* Remove top-level template in favour of multiple templates

* Remove unintentional hyphens, reword feature request template
 2018-11-13 17:45:57 +00:00
Patrik Nordwall
d36d70ee63
Merge pull request #25904 from akka/allowMoreTimeForDockerBindStartup 
Allow more time for docker bind startup
 2018-11-13 15:08:10 +01:00
Patrik Nordwall
f30f3b2104
Merge pull request #25906 from woq-blended/master 
Adding OSGi settings for akka-actor-typed and persistence-typed.
 2018-11-13 15:07:00 +01:00
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
Andreas Gies
42fb18936f Adding OSGi settings for akka-actor-typed and persistence-typed. 2018-11-12 20:10:20 +01:00
Arnout Engelen
01a496efd5 Allow more time for docker bind startup (#25855) 2018-11-12 09:11:15 +01: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