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

21509 commits

This branch
This branch
All branches
Author SHA1 Message Date
James Roper
2e71b751bf Provide meaningful name for SubSource.out/SubSink.in (#23922) 
Fixes #23921

Ensures that when an erroneous invocation of a method on `SubSink` or
`SubSource` (eg, push when not allowed), that the source of the
invocation can more easily be identified. Since the invocations on these
are generally through async callbacks, the stack trace can't be used to
help, hence why the name of the inlet/outlet (which will be included in
the error message) is so important.
 2017-11-06 19:30:12 +09:00
Johan Andrén
c8748e8cf0
#23848 Align typed persistence API with ReplicatedEntity API 
* Single effect factory companion, rather than concrete types - Improves discoverability and hides implementation details (hopefully making maintenance, ensuring bin comp. etc. easier)
* Actions renamed to CommandHandler
* Rename applyEvent to eventHandler - Especially makes sense after renaming actions to command handler
* Rearrange parameters from most stable to least stable
* onRecoveryCompleted cannot modify state
* Full types for function parameters to make the API easier to understand
 2017-11-02 14:39:56 +01:00
Martynas Mickevičius
9506c7d949 #23861 Test maximum burst immediatelly after drain 2017-11-02 14:38:02 +01:00
Arnout Engelen
cb2e003a85 Avoid javax.xml in SerializeSpec (#23903) (#23905) 
Neater anyway, and would become problematic with jdk9
 2017-11-02 21:40:14 +09:00
Martynas Mickevičius
1f5da40319 #23880 Set sources for doc task to empty, as skip does not seem to work (#23900) 2017-11-02 21:11:43 +09:00
Christopher Batey
5a37cdc862 Cross DC gossip fixes #23803 
* Adjust cross DC gossip probability for small nr of nodes in a DC
When a Dc is being bootstrapped the initial node has no local peers and
can not gossip if it selects a local gossip round. Start at a
probability of 1.0 for a single node cluster and move down 0.25 per node
until a 5 node DC is reached then use the cross-data-center-gossip-probability
* Fix cross DC gossip selecting of oldest members
This used to select the members based on the sort order members in
Gossip (by address) rather than by upNumber
 2017-11-02 09:17:24 +01:00
Richard Imaoka
a50df1c575 Add combinedMat method to Source (#23809) 
* Add combinedMat method to Source

* Fix formatting
 2017-11-02 10:34:40 +09:00
Richard Imaoka
0988933fac Stream cookbook sample for adhoc source (#23761) 2017-11-01 15:24:05 +01:00
Arnout Engelen
8eae33f40c Update to scala 2.12.4 (#23896) 
* Enable (and prefer) scala 2.12.4

* Keep 2.11 the default
 2017-11-01 23:14:05 +09:00
Christopher Batey
3cad104107
Merge pull request #23877 from RaymondKlass/stream_doc_typo 
fix missing letter typo in stream-flows-and-basics #23876
 2017-11-01 14:11:03 +00:00
Ritesh Puj
67da5359a0 Update logging.md (#23892) 
Anchor text changed from SL4FJ to SLF4J
 2017-11-01 10:49:42 +01:00
Christopher Batey
511180ef39 Stop actor system from shutting down on Cluster.leave (#23872) 
This then sets a race bewtween the rest of the test running as once the
ActorSystem shuts down test test coordinator won't for for barriers etc.
 2017-10-31 19:02:28 +01:00
Martynas Mickevičius
e460d40f6a
Merge pull request #23884 from 2m/wip-do-not-publish-doc-2m 
#23880 Do not generate api doc for NoPublish projects
 2017-10-31 16:56:11 +02:00
Patrik Nordwall
919c4f690f
Merge pull request #23883 from akka/wip-log-ignore-gossip-patriknw 
fix confusing logging when receiving gossip from unknown
 2017-10-31 15:02:42 +01:00
Martynas Mickevičius
5cf29a65a4
#23880 Do not generate api doc for NoPublish projects 2017-10-31 15:52:15 +02:00
Patrik Nordwall
86712d5b40 fix confusing logging when receiving gossip from unknown 2017-10-31 14:05:51 +01:00
Patrik Nordwall
90f0963982
Merge pull request #23870 from akka/formatDocsAndCodeConsistently 
Format docs like we do our own code
 2017-10-31 11:30:41 +01:00
Sergiy Prydatchenko
f2ebe60b95 Fix excessive rebalance in LeastShardAllocationStrategy (#23830) (#23834) 
* Having maxSimultaneousRebalance > rebalanceThreshold in LeastShardAllocationStrategy caused shards "flapping" (deallocation of excessive shards followed by their immediate allocation on the same node)
 2017-10-31 19:28:36 +09:00
Patrik Nordwall
0f503b0758
Merge pull request #23826 from agolubev/23614-Java-AbstractActor-doc-issues-agolubev 
Fix Java Actor doc issues for 2.5 update
 2017-10-31 11:14:27 +01:00
Patrik Nordwall
a2eb173882
Merge pull request #23875 from SethTisue/community-build-2.13 
fix 2.13 version checking in MiMa config
 2017-10-31 11:13:13 +01:00
Ray Klass
c7bc0ea81a fix missing letter typo 2017-10-30 21:56:06 -04:00
Seth Tisue
58feb2ba0d fix 2.13 version checking in MiMa config 
scalaBinaryVersion doesn't become simply "2.13" until Scala 2.13.0
is released (sometime in 2018)
 2017-10-30 11:00:52 -07:00
Richard Imaoka
c05a3e0e26 Fix Scaladoc for recoverWithRetries (#23762) (#23763) 2017-10-30 16:21:44 +01:00
Christopher Batey
3bef488faf
Merge pull request #23865 from akka/wip-23862-getCallerName-patriknw 
improve AkkaSpec.getCallerName, #23862
 2017-10-30 10:14:39 -05:00
Christopher Batey
51bb0407ae
Merge pull request #23871 from akka/wip-23844-shm-leak-patriknw 
shm leak in ClusterSingletonProxySpec, #23844
 2017-10-30 10:13:51 -05:00
Christopher Hunt
aa2ab4b6e2 Remove shutdown hook on shutting down (#23866) 
When shutting down, we compliment the addition of a shutdown hook during startup with its removal. Doing so further ensures that no class loader is retained when unloading Akka in an OSGi style scenario.
 2017-10-30 15:09:38 +01:00
Alexander Golubev
6d4074e4f0 =doc Java Actor doc for 2.5 updates 2017-10-30 10:00:02 -04:00
Patrik Nordwall
bef1ea0db4 shm leak in ClusterSingletonProxySpec, #23844 2017-10-30 14:53:41 +01:00
Christopher Batey
83a97256cc Turn on gossip logging for flaky test + improve test error msg (#23868) 2017-10-30 14:52:58 +01:00
Patrik Nordwall
70f2fc9622 harden RemoteReDeploymentSpec, #20180 (#23867) 2017-10-30 14:47:15 +01:00
Christopher Batey
2ee51c602a Compression level for gzip flow (#23845) 
Excluded binary compay check of Compressors as they are InternalApis
 2017-10-30 22:40:20 +09:00
Arnout Engelen
c9ab1b9ffb Format docs like we do our own code 
Though it seems we already did?
 2017-10-30 13:57:42 +01:00
Arnout Engelen
a2cbff1061
Switch languages in paradox without page refresh (#23544) 2017-10-30 13:45:30 +01:00
Martynas Mickevičius
34891df7e3 Update to Sbt 1.0.3 (#23860) 2017-10-30 19:42:32 +09:00
Patrik Nordwall
5e9a152a13 improve AkkaSpec.getCallerName, #23862 2017-10-30 11:11:06 +01:00
Martynas Mickevičius
82ca8a2cc7 Port build to SBT 1.x (#23850) 
* Port build to SBT 1.x

* Fix multinode tests, always enable genjavadoc bootstrap
 2017-10-30 10:13:13 +09:00
Christopher Batey
38622246d9 Fix typos in binary compatibility doc (#23846) 2017-10-25 10:35:52 +09:00
Arnout Engelen
b8a18bcf30 Nicer message when expectCancellation() fails (#23847) 2017-10-25 09:14:21 +09:00
Patrik Nordwall
85ab0efbd8 Merge pull request #23840 from johanandren/wip-23796-disallow-null-message-johanandren 
Fail fast on null messages in Akka Typed
 2017-10-24 15:14:43 +02:00
Christopher Batey
70ad537af5 Retry creation of ActorSystem in remoting tests #23481 (#23769) 
* Retry creation of ActorSystem in remoting tests #23481

Remoting multi-jvm test rely on setting port = 0 which selects an open
port. This has a race where two of the JVMs open/close the same port
then configure their ActorSystem with it so one of them fails to start
due to the port being in use. This adds a simple retry so another port
is selected.
 2017-10-24 14:22:25 +02:00
Martynas Mickevičius
da0cfa577b Log coordinated shutdown as debug (#23839) 2017-10-24 18:15:11 +09:00
Johan Andrén
be1e25f4d1 Fail fast on null messages #23796 2017-10-24 11:10:57 +02:00
Patrik Nordwall
bcce7bd8c1 fix wrong inheritance of AbstractPersistentLoggingFSM, #23436 (#23831) 2017-10-24 09:57:38 +09:00
Patrik Nordwall
d4b06b7c77 Merge pull request #23829 from akka/wip-donot-inherit 
=str mark overflow strategies with DoNotInherit
 2017-10-23 08:38:08 -05:00
Richard Imaoka
7c38cc1b54 Use scaladoc and javadoc directives in stages-rate.md (#23811) 
* Use scaladoc and javadoc directives in stages-rate.md (#22904)

* Update build.sbt
 2017-10-23 08:03:03 -05:00
Arnout Engelen
9cb5849188 Accept 'Join' messages from nodes without dc (#23822) 
* Accept 'Join' messages from nodes without dc

To allow a join from a 2.4 node to a 2.5.6 cluster.

* Use "ClusterSettings.DefaultDataCenter" constant
 2017-10-23 04:49:51 -05:00
Konrad `ktoso` Malawski
2e5f6bebc0 =str mark overflow strategies with DoNotInherit 
Since they are `sealed` but could still be extended by in java, so calling this out via annotation that they're not intended to be extended.
 2017-10-23 18:49:07 +09:00
Patrik Nordwall
e4980b323c Merge pull request #23827 from victornoel/doc-persistence-leveldb-deps 
Clarify leveldb dependencies in docs (#22816)
 2017-10-23 04:06:19 -05:00
Patrik Nordwall
4991434f32 Merge pull request #23818 from chbatey/untyped-behavior-spawn 
Spawning of typed persistent actors from untyped ActorSystem
 2017-10-23 04:02:19 -05:00
Victor Noël
566bde1d69 =doc Clarify leveldb dependencies in docs (#22816) 2017-10-22 12:48:23 +02:00