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

21598 commits

This branch
This branch
All branches
Author SHA1 Message Date
Arnout Engelen
ca3fa778d6
Check all dependencies, except NoPublish ones, fail on error (#24021) 2017-11-20 13:25:17 +01:00
Arnout Engelen
306276af76
Update whitesource to 0.1.7 (#24001) 
Giving more clarity on which whitesource project/product name is used
and better output when a violation is found.

I noticed whitesource errors during our pr validation, this might help
pinpointing what's going on there.
 2017-11-20 10:19:46 +01:00
Johan Andrén
6db974b6f4 No submaterializing inner source when outer stream already canceled (#23723) 
* Do not try to submaterialize inner source when outer stream already cancelled #23656

* Use StreamDetachedException

* Sleep a little

* Updated exception text
 2017-11-17 12:24:12 +01:00
Patrik Nordwall
edcc2b2d75
Merge pull request #23805 from johanandren/wip-23798-observe-tcp-unbind-johanandren 
Make TCP server unbinding observable
 2017-11-17 12:22:27 +01:00
Patrik Nordwall
a5db7bc950
Merge pull request #23978 from moogpwns/doc-23966-getting-started-snppet 
Docs - Java snippets for Getting Started Guide Part 4 #23966
 2017-11-17 12:21:10 +01:00
Alexander Golubev
a7b1a6675b Add throttle combinator without bucket size in parameters (#23808) 
* +str Add throttle combinator without bucket size in parameters

* Add mima filter plus comment formatting

* Reviwed throttle messages across all classes

* move mima filter to 2.4.6

* change to throttleEven, plus grammar fixes

* fix formatting

* changed mima filter according to new API

* fixes accoring to feedback
 2017-11-17 12:20:12 +01:00
Johan Andrén
b315cb787c The right place for MiMa excludes 2017-11-17 11:34:05 +01:00
Johan Andrén
ea76a0c4d3 One more tryFailure 2017-11-17 11:33:17 +01:00
Johan Andrén
acdabeff74 Mima 2017-11-17 11:33:17 +01:00
Johan Andrén
bdfcbc28da Try fail in case the unbind promise was already completed 2017-11-17 11:33:17 +01:00
Johan Andrén
7bdd6c8934 Put those @params last 2017-11-17 11:33:17 +01:00
Johan Andrén
4c1410c3b5 Complete unbind promise earlier if possible and always in postStop 2017-11-17 11:33:17 +01:00
Johan Andrén
c830a75bd0 Mima and internalizing things that should have already been internal 2017-11-17 11:33:17 +01:00
Johan Andrén
1c35429a9b Formatting 2017-11-17 11:33:17 +01:00
Johan Andrén
057e03ebe2 Make TCP server unbinding observable #23798 2017-11-17 11:33:17 +01:00
Patrik Nordwall
b51d720b18
Merge pull request #24006 from akka/wip-24003-permit-patriknw 
fix double return of recovery permit, #24003
 2017-11-17 10:58:47 +01:00
Johan Andrén
3dc0adb4e9 Handle race where broadcasthub consumer already cancelled (#23970) 
* Handle race where broadcasthub consumer already cancelled #23205

* Don't use the same thread ec, import cleanup

* Complete feedback promise when async event has been executed #23953

* No need for double-deregister-guard after invokeWithFeedback was fixed.

* Test coverage for async callbacks #23953

* Updated docs on AsyncCallback #23953

* MiMa

* Completing a promise of scaladoc

* Improved test coverage and handling of async invokation failing or throwing

* MiMa

* Review updates
 2017-11-17 10:55:30 +01:00
Arnout Engelen
26cd916d98 Make imports explicit in timer example (#24010) 2017-11-17 08:07:37 +00:00
Christopher Batey
983bfdeeb7
Merge pull request #24012 from akka/jr/w/fix-VirtualPublisher-Strings 
=str cosmetic changes to VirtualPublisher
 2017-11-17 08:06:53 +00:00
Oleg Skovpen
ef515976e9 Fix typo (#24008) 2017-11-16 10:22:55 +09:00
Patrik Nordwall
60e7a4088d fix double return of recovery permit, #24003 
* when exception was thrown from RecoveryCompleted the
  permit was returned twice, resulting in negative balance
 2017-11-15 18:16:26 +01:00
Johannes Rudolph
88daf2e2dd =str cosmetic changes to VirtualPublisher 2017-11-15 17:04:50 +01:00
Patrik Nordwall
1f8b0137a8
Merge pull request #23991 from akka/wip-23198-FanOutThrougputSpec2-patriknw 
fix flow control in FanOutThroughputSpec, #23198
 2017-11-15 14:12:41 +01:00
Christopher Batey
1eb3abb27e
Fix lookup of coordinator for sharding proxies (#23995) 2017-11-15 13:03:48 +00:00
Patrik Nordwall
9e506b25b7 disambiguate serializer in typed ClusterShardingSpec, #23993 (#23999) 
* test was not always using serialization because it was just one
  entity which could be local or remote
* the test serializer was wrong
* multiple serializers found so was using java serializer
 2017-11-15 13:02:18 +00:00
Renato Cavalcanti
f92e1c16e7 Add overloaded Effect.persist and renaming Effect.done to none #23964 2017-11-14 16:48:10 +01:00
Arnout Engelen
09d79d5981
Include the full apache license text (#23992) 
Hopefully GitHub will recognize it then. Kept the link to http://akka.io/docs/akka/snapshot/project/licenses.html and the note about protobuf at the bottom, hopefully that doesn't throw them off.
 2017-11-14 16:47:33 +01:00
Konrad `ktoso` Malawski
f19dcbeff3 =str #23933 materialization failing hard with nicer message now 2017-11-14 15:56:02 +01:00
golem131
2f2fdd0264 Dependency updates (#23852) 
- Scala 2.12.3 -> 2.12.4
- gson 2.8.1 -> 2.8.2
- metrics-core 3.2.4 -> 3.2.5
- metrics-jvm 3.2.4 -> 3.2.5
- HdrHistogram 2.1.9 -> 2.1.10
 2017-11-14 14:08:30 +00:00
Patrik Nordwall
5ebe723e9c fix flow control in FanOutThroughputSpec, #23198 2017-11-14 14:59:07 +01:00
Christopher Batey
9c119b321a Improve error message for AbstractPersistentFSMTest failure (#23985) 
This once failed where the intial shopping cart before adding an item
was not empty. I've also changed the item prices to be different for
each test just in case we're picking up state from a previous test
(which seems unlikey given the pid is a random uuid)
 2017-11-14 21:57:16 +09:00
Patrik Nordwall
983e9c1f89
Merge pull request #23988 from akka/wip-23198-FanOutThrougputSpec-patriknw 
adjust burstSize in FanOutThrougputSpec, #23198
 2017-11-14 13:57:07 +01:00
Patrik Nordwall
5bf2bfecd7
Merge pull request #23776 from akka/wip-23772-serializer-ShardingEnvelope-patriknw 
add serializer for typed ShardingEnvelope, #23772
 2017-11-14 13:39:24 +01:00
Patrik Nordwall
eefd6869a5 adjust burstSize in FanOutThrougputSpec, #23198 2017-11-14 12:28:27 +01:00
Patrik Nordwall
3307df69b5
Merge pull request #23986 from akka/wip-23552-proxy-separation-patriknw 
Separate sharding regions and proxies, #23472
 2017-11-14 12:21:18 +01:00
Heiko Seeberger
52d1f54a9a Clarify ScalaDoc of Actor.immutable (closes #23977) (#23982) 2017-11-14 11:09:24 +00:00
Patrik Nordwall
985afe8020 add serializer for typed ShardingEnvelope, #23772 2017-11-14 12:03:34 +01:00
Patrik Nordwall
64669bc55f additional hardening of RemoteReDeploymentSpec, #23838 2017-11-14 11:54:16 +01:00
Unknown
6587d9e522 Separate sharding regions and proxies, #23472 2017-11-14 11:42:13 +01:00
Patrik Nordwall
de00efc405
Merge pull request #23980 from akka/wip-23198-FanOutThrougputSpec-pending-patriknw 
mark FanOutThrougputSpec as pending, #23198
 2017-11-14 10:04:48 +01:00
Christopher Batey
6617230258
Merge pull request #23975 from johanandren/wip-21839-verbose-tcp-termination-test-johanandren 
Make the actor-terminate-unexpectedly test more verbose
 2017-11-14 08:10:51 +00:00
Patrik Nordwall
68a2b2fa6e mark FanOutThrougputSpec as pending, #23198 
* and include right name in the === prints
 2017-11-14 08:38:36 +01:00
Konrad `ktoso` Malawski
af411d2f8d
=pro #23931 define automatic module names explicitly (#23960) 
* =pro #23931 define automatic module names explicitly (otherwise would be akkaactor_2.12) etc

Read:
- http://blog.joda.org/2017/04/java-se-9-jpms-module-naming.html
- http://mail.openjdk.java.net/pipermail/jpms-spec-experts/2017-February/000582.html
- http://blog.joda.org/2017/05/java-se-9-jpms-automatic-modules.html

for rationale

* Update build.sbt

* Update build.sbt
 2017-11-14 11:41:37 +09:00
Mark James
711ac5730b Docs - re-order Java snippet delimiters for Getting Started Guide Part 4 #23966 2017-11-14 00:50:29 +01:00
Johan Andrén
77da944ed7 Make the actor-terminate-unexpectedly test more verbose in case it fails again #21839 2017-11-13 16:57:21 +01:00
Patrik Nordwall
1cdd205c02
Merge pull request #23882 from chbatey/issue-23775-multidc-split 
Increase time for MultiDcSplitBrain and increase cross DC gossip prob
 2017-11-13 15:26:10 +01:00
Martynas Mickevičius
d1b53ac1d3 #23484 Fortify RestartSpec 2017-11-13 15:24:13 +01:00
James Roper
92313cb08a Improve error message when pushing unpulled outlet (#23923) 
* Improve error message when pushing unpulled outlet

If an outlet is pushed to before it has been pulled, the error message
is "Cannot push twice", which makes sense if after receiving a pull, you
push twice, but makes no sense if you never received a pull in the first
place. This improves the error message to avoid confusion.

* Reword message slightly
 2017-11-13 22:15:05 +09:00
nachinius
53bbd5ab5f Allow RestartSource.withBackoff to restart only on failures #23881 (#23911) 
* Allow RestartSource.withBackoff to restart only on failures #23881
 2017-11-13 13:47:27 +01:00
Christopher Batey
4d3a7e93a6 Increase timeout and remove sleep 
The test has been failing infrequently as when we get to the final
barrier (restarted-fifth-removed) the whole test withIn of 40s
has been reached so the last barrier times out right away.

Trying to remove the Thread.sleep and rely on a larger timeout for the
whole test as well as the default barrier timeout of 30s.
 2017-11-13 12:20:56 +00:00