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

22296 commits

This branch
This branch
All branches
Author SHA1 Message Date
Arnout Engelen
6835199ce9
Link from github issue template to discuss.akka.io 2018-06-06 11:48:11 +02:00
Ignasi Marimon-Clos
9f6fc2d6da Configure exit code and Coordinated Shutdown per-reason overrides (#25186) 
* Enable exit code configurability

* Rollback first approach. Implement override

* Support overriding exit-jvm and terminate-actor-sys

* Simplifies code handling overrides
 2018-06-06 08:45:55 +01:00
李晨曦
cab48ba699 Correct a word 'degredation' (#25207) 2018-06-06 08:43:44 +01:00
Patrik Nordwall
7f8f3c122b
Merge pull request #25137 from akka/wip-24856-EventHandler-alias-patriknw 
add EventHandler type alias, #24856
 2018-06-05 10:54:12 +02:00
Viktor Klang (√)
eddc61af82 Documentation updates for Akka Persistence Typed (#25194) 
* Switching to throwing exceptions in documentation suggestions
 2018-06-05 09:49:01 +01:00
Christopher Batey
01f90ad95d
Add common multi node cluster config to all cluster sharding tests (#25202) 2018-06-05 06:58:17 +01:00
Christopher Batey
2a979fe296 Expose Effect classes for BehaviorTestKit Java DSL, #25070, #24781 
* Expose Effect classes for BehaviorTestKit Java DSL

- Share effect classes between java and scala dsl
- make spawn adapter private
- add message adapter effect
- add tests for java behavior test kit

* Mirror Effect factory in java and scala dsl
 2018-06-04 18:01:09 +02:00
Patrik Nordwall
356415014f
Merge pull request #25192 from chbatey/issue-25190 
Harden typed MultiDcClusterSharding
 2018-06-04 17:32:50 +02:00
Patrik Nordwall
aceb4d6aa3 add EventHandler type alias, #24856 
* for completeness, since we have one for CommandHandler, and sometimes
  it might be useful with the shorter type signature
* use the explicit function type for CommandHandler in API signatures,
  because it's easier to see what it actually is
 2018-06-04 15:40:10 +02:00
Christopher Batey
1787283757 Log receiving of heartbeats when verbose heartbeat logging is on (#25183) 2018-06-04 16:22:06 +03:00
Christopher Batey
5bde26dca6 Fix ClusterShardingIncorrectSetup barrier (#25187) 
Barrier needs to be one line down otherwise can fail:
http://jenkins.akka.io:8498/job/akka-artery-cluster-tests/1364/consoleFulllusterShardingIncorrectSetupMultiJvmNode1
 2018-06-04 15:04:18 +02:00
Christopher Batey
f68887cef0 Fix RemotingFailedToBindSpec #24579 
It was finding a free udp port to use rather than tcp
 2018-06-04 13:48:31 +03:00
Christopher Batey
989e59406e Harden typed MultiDcClusterSharding 
The test failed as the Register message is ignored the first time and
the timeout (3s) doesn't give much time for further retries.

Reduce the retry interval rahter than incrase the timeout.
 2018-06-04 08:18:39 +01:00
Patrik Nordwall
85c37f4aeb
Merge pull request #25165 from fjeremic/openj9-unsafe 
Make copyUSAsciiStrToBytes more robust w.r.t. JDK
 2018-06-01 15:09:52 +02:00
Patrik Nordwall
6897ea931e
Merge pull request #25179 from akka/chbatey-patch-1 
Upgrade to SBT 1.1.6
 2018-06-01 15:08:55 +02:00
Tim Moore
dd01f9672c Update sbt-whitesource to 0.1.12 (#25180) 
Changes:

- https://github.com/lightbend/sbt-whitesource/releases/tag/v0.1.11
- https://github.com/lightbend/sbt-whitesource/releases/tag/v0.1.12
 2018-06-01 11:05:10 +02:00
Christopher Batey
f9305587c6
Upgrade to SBT 1.1.6 2018-06-01 07:48:29 +01:00
jorgesg1986
fceca07ec0 Added log messages when leadership is gained or lost (#25053) 2018-05-31 15:43:53 +02:00
Christopher Batey
d03f21a35a
Suggest ClusterSharding hasn't been started in log message (#25177) 2018-05-31 14:43:06 +01:00
Tim Moore
5c401584c3 Add static import convenience methods to Done and NotUsed (#25174) 
* Add Done.done() convenience for static import
* Add NotUsed.notUsed() convenience for static import
 2018-05-31 13:12:20 +01:00
Christopher Batey
c8f4a17025
Clarify typed supervision when returning a new behavior (#25163) 2018-05-31 13:07:15 +01:00
Patrik Nordwall
ec23844db6
Merge pull request #25170 from laszlovandenhoek/takeWhileJavaDSL 
eliminate extraneous takeWhile$default$2 method in Java DSL
 2018-05-31 13:33:12 +02:00
László van den Hoek
e12a492679 eliminate extraneous takeWhile method 2018-05-31 10:56:27 +02:00
Johan Andrén
333c05da60 Hopefully fixed a race in the shutdown test (#25155) 2018-05-31 07:55:13 +01:00
Doug Roper
b6d6d543a8 Optimize ByteString.grouped(size) (#25153) 
* Add ByteString.grouped() benchmark & tests.

* Implement ByteString.grouped().

* PR comments.
 2018-05-30 23:31:35 +09:00
Patrik Nordwall
a14347e18d
Merge pull request #25167 from akka/chbatey-patch-1 
Update stream-integrations.md
 2018-05-30 13:37:41 +02:00
Christopher Batey
3c12196d22
Update stream-integrations.md 2018-05-30 11:33:25 +01:00
Sergey Kisel
f4cc1dd0f9 ScanAsync handling fully complete stream while future is resolved #25112 2018-05-30 13:01:18 +03:00
Filip Jeremic
33b8fb298c
Make copyUSAsciiStrToBytes more robust w.r.t. JDK 
* The `copyUSAsciiStrToBytes` API assumes that the JDK's representation of String value arrays are always of equal length to the String object itself. This may not be the case for all JDKs, and in particular it is not the case in Java 8 version of OpenJ9 [1].

* To make akka more robust we use the `length()` method to retrieve the length of the String object rather than assuming the value array is always of the same size. This should not cause any performance differences as the length method is quite small and should always be inlined.

Fixes: #25161

[1] https://github.com/eclipse/openj9

Signed-off-by: Filip Jeremic <fjeremic@ca.ibm.com>
 2018-05-29 17:36:54 -04:00
Christopher Batey
a7d94db803 Routing docs: Fix typo and clarify group behavior (#25162) 2018-05-29 21:07:21 +09:00
Christopher Batey
485179c5f6 ClusterDeathWatchSpec: assert cluster status bewtween tests (#25126) 
Test failed due to node4 still seeing node3 in a subsequent test
but assumed it had been removed.

Fixes #25065
 2018-05-29 13:38:20 +02:00
Doug Roper
034f6c5c96 Remove unnecesary drop() from ByteString1.writeToBuffer(ByteBuffer) (#25151) 
I found a strange call to `drop()` in `ByteString1.writeToBuffer(ByteBuffer)`. `drop()` instantiates a new `ByteString1` which is immediately discarded to GC. Appears unnecessary.

Removing it makes the `ByteString1` implementation match the one `ByteString1C`.
 2018-05-29 20:13:07 +09:00
Patrik Nordwall
73284fd897 log discarded messages in read-only endpoint #25127 2018-05-29 12:47:09 +02:00
Jimin Hsieh
7c3a8a8ed5 java.time.Duration APIs in javadsl.TestKit #24646 2018-05-29 12:17:48 +02:00
Linh Nguyen
e078e5a747 Add return type for FlowMonitorState.finished #24885 2018-05-29 12:08:13 +02:00
Richard Imaoka
a17a61557c doc Replace the word stage by operator in stream doc (#25138) 2018-05-29 10:00:48 +02:00
Patrik Nordwall
1919f222fa
Merge pull request #25154 from akka/wip-25143-neg-ack-log-patriknw 
limit negative acknowledgement logging, #25143
 2018-05-28 11:45:26 +02:00
Patrik Nordwall
cf864a940f limit negative acknowledgement logging, #25143 2018-05-28 09:11:51 +02:00
Martynas Mickevičius
3d61400409 Decrease the uninitialized connection counter as late as possible #25148 
This fixes (or decreases the chances significately for) a
situation where a stream of incoming connections is closed
and the incoming connection does not have a chance to startup
properly.
 2018-05-25 16:22:48 +02:00
Richard Imaoka
84d53d1ad1 Persistence: replace initialState with emptyState (#25129) 2018-05-25 14:29:22 +02:00
Christopher Batey
8eb7b1ea81
Typed persistent event adapters/wrappers (#25050) 
Typed persistent event adapters/wrappers
 2018-05-25 10:23:04 +01:00
Arnout Engelen
c8064d069b
Merge pull request #25139 from ortex/fix-graph-stage-logging-docs 
fix graph stage logging docs
 2018-05-25 10:13:12 +02:00
Max Calderoni
c6b1f9b884 =doc wording improvement in stream-graphs.md subjunctive (#25145) 2018-05-25 14:59:59 +09:00
ortex
ea4fe1ba99 using unidoc for graph stage logging docs 2018-05-25 02:14:16 +03:00
Arnout Engelen
49322afae0 Update scala-java8-compat (#25142) 
* Update scala-java8-compat

* Update scala-java8-compat only for scala 2.13

As it looks like 0.8.0 is not bincompat with 0.9.0
 2018-05-24 23:08:22 +09:00
Doug Roper
8286ecffc5 Fix MultiByteArrayIterator.copyToArray silently drops bytes. #16303 (#25141) 
I just got burned by #16303.

Answering https://github.com/akka/akka/issues/16303#issuecomment-62957914, it looks like `copyToArray[B >: Byte](Array[B])` can't call `getBytes(Array[Byte], Int, Int)` due to the type constraint (defined by `GenTraversableOnce`).

Instead, I'm going with the simple `isEmpty` solution proposed in the description of #16303 by @kpatrick-kixeye.
 2018-05-24 16:11:50 +09:00
Andrew Bushmin
6a7488fa19
fix graph stage logging docs 2018-05-23 23:29:39 +03:00
Arnout Engelen
d08ebf4552
Merge pull request #24941 from hepin1989/deadleater 
= actor add clarify message to dead letter listener
 2018-05-23 12:25:16 +02:00
Konrad `ktoso` Malawski
6b204ff121
add missing have for past tense 2018-05-23 01:39:52 +09:00
虎鸣
8736d2a407 = actor add clarify message to dead letter listener 2018-05-22 22:59:55 +08:00