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

22748 commits

This branch
This branch
All branches
Author SHA1 Message Date
Arnout Engelen
2ae71dfc32 Don't set bootclasspath when already on jdk8 2018-11-22 13:01:33 +01:00
Jakub Czuchnowski
1d36879e53 Add missing for Custom Stream Processing docs #25940 (#25941) 2018-11-19 10:29:10 +01:00
Christopher Batey
0bf0f1a955 Remove typed DeadLetter class (#25944) 
Typed actor system does not wrap dead letters in this, likely left over
from the native impl.
 2018-11-19 09:30:12 +01:00
Patrik Nordwall
caec209bf6
Merge pull request #25932 from chbatey/uncomment-test 
Uncomment ConstantRateEntityRecoveryStrategySpec
 2018-11-18 20:03:09 +01:00
Patrik Nordwall
11e9060dfb
Merge pull request #25938 from chbatey/sharding-start-overloads 
Cluster sharding start overlods to avoid passing in settings
 2018-11-18 19:34:51 +01:00
Patrik Nordwall
2801180b07
Merge pull request #25939 from chbatey/cluster-provider-msg 
Include configuration name in log when cluster not actor provider
 2018-11-18 18:38:46 +01:00
Christopher Batey
c8013d54f3 Include configuration name in log when cluster not actor provider 2018-11-16 15:58:59 +00:00
Christopher Batey
1510f43297 Cluster sharding start overlods to avoid passing in settings 2018-11-16 13:06:56 +00:00
Christopher Batey
6c279aa271 Uncomment ConstantRateEntityRecoveryStrategySpec 2018-11-15 16:48:43 +00:00
Helena Edelson
f872115512 Cluster event listener that logs all events #25832 (#25918) 2018-11-15 17:31:58 +01:00
Arnout Engelen
40649151d0 Document docker resource limits (#25925) 
* Document docker resource limits

* No longer experimental on JVM10
 2018-11-15 15:48:57 +00:00
Oliver Burkhalter
40483a2506 Improve Getting Started Guide Part 3 for writing a first Actor test #25193 2018-11-15 12:55:29 +01:00
Dale Wijnand
fb326b7f01 Cleanup BackoffSupervisor (#25898) 
* Dedup scheduleRestart in BackoffSupervisor

* Use show type names in scope

* Finish importing BehaviorInterceptor's types
 2018-11-14 17:04:59 +00:00
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