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

21040 commits

This branch
This branch
All branches
Author SHA1 Message Date
Richard Imaoka
bf13cbe9c1 Add hyperlink to Lightbend Enterprise Suite (Fixes #23022) 2017-06-16 11:01:45 +09:00
Richard Imaoka
1d2748cad2 Merge paradox/scala/howto.md and java/howto.md (#23159) 2017-06-14 06:27:46 -07:00
Richard Imaoka
b05cd61ca2 Merge java/fault-tolerance-sample.md with scala/fault-tolerance-sample.md (#23160) 2017-06-14 05:27:59 -07:00
Packt
1d5d14d0b1 Updated books.md (#23157) 
Added new book link on Akka
 2017-06-14 14:25:03 +02:00
Johan Andrén
698223ae48 Copied as little as possible of the deprecated stuff from sbt (#23147) 2017-06-14 14:19:43 +02:00
Richard Imaoka
f376d2c6c7 Merge paradox/scala/extending-akka.md and java/extending-akka.md (#23156) 2017-06-14 02:01:27 -07:00
Richard Imaoka
48c8c1ab91 Merge paradox/scala/cluster-usage.md and java/cluster-usage.md (#23154) 
* Identical contents in scala/cluster-usage.md and java/cluster-usage.md for easier review

* Replace java/cluster-usage.md with a symlink to scala/cluster-usage.md
 2017-06-14 01:52:01 -07:00
Richard Imaoka
17e07c0ae2 Merge paradox/scala/event-bus.md and java/event-bus.md (#23155) 2017-06-14 01:05:13 -07:00
Duncan DeVore
f90133499a =act #23067 by adding logging for None message (#23103) 
* fixes #23067 by adding logging for None message

* changed to log and then throw exception

* cleaned up fromBinary logging message
 2017-06-14 16:27:33 +09:00
Johan Andrén
2393569df2 Ignore unknown messages in LoggingReceiveSpec #23140 2017-06-13 15:37:17 +02:00
Roman Tkalenko
e2e15b9298 Adds scaladoc to each CoordinatedShutdown phase (#23148) 2017-06-13 04:01:55 -07:00
Konrad `ktoso` Malawski
b7d7316c1c =str #22917 recoverWithRetries allow 0 and negative values 2017-06-13 11:18:46 +02:00
Arnout Engelen
ee79a3d1a8 Update whitesource report on release (#23146) 2017-06-13 11:18:24 +02:00
Andrea Peruffo
359ed15cec =doc passive mode for fiddles (#23145) 2017-06-13 11:17:40 +02:00
Patrik Nordwall
5b9f71a2a0 Merge pull request #23143 from akka/wip-23099-camel-master-patriknw 
Forward port of Camel PRs, #23099 (for validation)
 2017-06-12 14:51:34 +02:00
Steven Lowenthal
b16d513c0b Produce child to send camel results or failures directly to its parent (Producer Actor) instead of itself and then forward 
(cherry picked from commit 9ef6f136b12fe158eb2fc234e755da2db0f5ae7a)
 2017-06-12 14:24:06 +02:00
Patrik Nordwall
8ca0aac2dc make it easier to configure dispatcher for Camel ProducerChild, #23099 
* and use parent dispatcher as default, better than default-dispatcher

(cherry picked from commit c911c06b9e60b88874cf9b608c64aa5a125e9794)
 2017-06-12 14:23:00 +02:00
Arnout Engelen
de3a48f2c3 Simplify whitesource configuration (#23141) 2017-06-12 03:22:41 -07:00
Ryan Case
f2c719b1fc Fix broken link for consistent hashing article (#23133) 
* Fix broken link for consistent hashing article

* Fix broken link for consistent hashing article in java docs
 2017-06-12 10:55:41 +02:00
Patrik Nordwall
8241cd95f6 Merge pull request #23051 from manuelbernhardt/patch-1 
Improving cluster specification documentation
 2017-06-12 10:23:18 +02:00
Patrik Nordwall
c76177247a Merge pull request #23137 from akka/wip-23010-ActorsLeakSpec-patriknw 
increase timeout in ActorsLeakSpec, #23010
 2017-06-11 14:20:20 +02:00
Patrik Nordwall
4f9921b8ee increase timeout in ActorsLeakSpec, #23010 
* follow up on #23010, ActorsLeakSpec sometimes fails
  because the reliableEndpointWriter is not stopped as
  early as before
 2017-06-11 13:30:43 +02:00
Patrik Nordwall
14617d3ed5 Merge pull request #23129 from akka/wip-23010-ResendUnfulfillableException-patriknw 
Fix ResendUnfulfillableException after transport failure detection, #23010
 2017-06-11 09:15:20 +02:00
Manuel Bernhardt
420a1fd7be Fixing typo and improving wording 2017-06-10 14:27:30 +02:00
Patrik Nordwall
32f0936d17 Fix ResendUnfulfillableException after transport failure detection, #23010 
Reproducer (TransportFailSpec):

* watch from first to second node, i.e. sys msg with seq number 1
* trigger transport failure detection to tear down the connection
* the bug was that on the second node the ReliableDeliverySupervisor
  was stopped because the send buffer had not been used on that side,
  but that removed the receive buffer entry
* later, after gating elapsed another watch from first to second node,
  i.e. sys msg with seq number 2
* when that watch msg was received on the second node the receive buffer
  had been cleared and therefore it thought that seq number 1 was missing,
  and therefore sent nack to the first node
* when first node received the nack it thrown
  IllegalStateException: Error encountered while processing system message
    acknowledgement buffer: [2 {2}] ack: ACK[2, {1, 0}]
  caused by: ResendUnfulfillableException: Unable to fulfill resend request since
    negatively acknowledged payload is no longer in buffer

This was fixed by not stopping the ReliableDeliverySupervisor so that the
receive buffer was preserved.

Not necessary for fixing the issue, but the following config settings were adjusted:
* increased transport-failure-detector timeout to avoid tearing down the
  connection too early
* reduce the quarantine-after-silence to cleanup ReliableDeliverySupervisor
  actors earlier
 2017-06-09 14:19:14 +02:00
Arnout Engelen
cd6b6ffe67 Add sbt-whitesource plugin (#23122) 2017-06-09 13:34:21 +02:00
Patrik Nordwall
c9131412fd Merge pull request #23064 from akka/testFailure23001 
Make fewer assumption about log msg ordering (#23001)
 2017-06-09 13:27:23 +02:00
Patrik Nordwall
d38cf19ad6 Merge pull request #23062 from akka/logMultiJvmTestDetails 
Be more specific about node/test for multi-jvm specs
 2017-06-09 13:25:29 +02:00
Patrik Nordwall
6652a368e3 Merge pull request #23069 from akka/remoteReDeploymentFailure 
Fix RemoteReDeploymentSpec instability (#20180)
 2017-06-09 13:20:48 +02:00
Patrik Nordwall
d80f92c25f Merge pull request #23082 from hseeberger/23081-docs-source-queue 
Fix docs for Source.queue (closes #23081)
 2017-06-09 13:15:14 +02:00
Patrik Nordwall
9f14dfad14 Merge pull request #23097 from akka/wip-doc-str-wat-fix-yes 
=str typo in exception, it is getStageActor
 2017-06-09 13:12:08 +02:00
Patrik Nordwall
31c9129b21 Merge pull request #23121 from akka/wip-percentile-patriknw 
Correction of HDR percentiles logging
 2017-06-09 12:55:20 +02:00
Arnout Engelen
571350612a Update camel to 2.15.6 (#23124) 2017-06-09 12:53:28 +02:00
Patrik Nordwall
afc541f2b8 Merge pull request #23127 from akka/wip-AeronStat-patriknw 
update AeronStat to 1.2.5
 2017-06-09 12:52:25 +02:00
Patrik Nordwall
56bfda115f update AeronStat to 1.2.5 
* this is pretty much a copy from aeron-samples
 2017-06-08 18:21:47 +02:00
Arpan Chaudhury
8456c3f2e0 changing java stages-overview.md stream-composition.md stream-flows-and-basics.md to symlinks (#23126) 2017-06-08 07:37:53 -07:00
Martynas Mickevičius
f20aea6b5e Merge pull request #22967 from 2m/wip-not-bound-address-2m 
#22889 Use port 0 for address which is supposed to never be bound
 2017-06-08 15:39:18 +02:00
Martynas Mickevičius
d0c0d91730 Merge pull request #22968 from johanandren/wip-final-sbt-deprecated-operator-fixes-johanandren 
Last sbt deprecation warnings fixed
 2017-06-08 14:04:37 +02:00
Johannes Rudolph
b3487eabe6 Merge pull request #23110 from jrudolph/jr/fix-source-queue-edge-cases 
=str break out a few source implementations into separate files
 2017-06-08 11:09:18 +02:00
Patrik Nordwall
db9ba53f6c Correction of HDR percentiles logging 
* previously it would typically report too low value for the higher
  percentiles, such as value at 98.5 percentile for 99 percentile
 2017-06-08 07:28:22 +02:00
Atiq Sayyed
d5155755db Merged the document from java/stream/stages-overview and scala/stream… (#23085) 
* Merged the document from java/stream/stages-overview and scala/stream/stages-overview #23084
* Merged the document from java/stream/stream-composition.md and scala/stream/stream-composition.md #23086
 2017-06-07 10:24:12 -07:00
Johan Andrén
168b40e40c Two unrenamed variable references fixed (#23120) 2017-06-07 18:00:02 +02:00
Arnout Engelen
41098a427f Some cleanups in ClusterClientSpec (#23095) 
Mainly replacing within+awaitAssert with awaitAssert with a timeout - seems
cleaner.
 2017-06-07 05:54:47 -07:00
Arnout Engelen
b80ee5e3d3 Log fatal errors to stderr, add exceptions to 'marked' errors (#23109) 
* Log fatal errors to stderr, add exceptions to 'marked' errors (#23107)

After logging to stderr it seems reasonable to include the exception
in the logging though the logging subsystem

* Add cause message to logging on fatal error

* Flush twice for extra safety

printStackTrace does some allocations, there might be rare cases where
we can at least salvage the cause.
 2017-06-07 05:52:26 -07:00
Richard Imaoka
48975a5ce0 Merge paradox/scala/cluster-sharding.md and java/cluster-sharding.md (#23112) 
* Identical contents in scala/cluster-sharding.md and java/cluster-sharding.md for easier review

* Replace java/cluster-sharding.md with a symlink to scala/cluster-sharding.md

* fix typo
 2017-06-07 02:11:35 -07:00
Richard Imaoka
32d1d006c7 Add mentions to akka.stream.impl.package and fix some typos. (Fixes #23073) (#23075) 2017-06-07 01:44:31 -07:00
Richard Imaoka
6c1d82a4e6 Merge paradox/scala/cluster-metrics.md and java/cluster-metrics.md (#23098) 
* Identical contents in scala/cluster-metrics.md and java/cluster-metrics.md for easier review

* Replace java/cluster-metrics.md with a symlink to scala/cluster-metrics.md

* Fix typo
 2017-06-07 01:43:18 -07:00
Richard Imaoka
711c0ff027 Move a warning on -optimize to CONTRIBUTING.md (Fixes #22932) (#23089) 2017-06-07 01:42:42 -07:00
Johannes Rudolph
084b1220ff =str break out a few source implementations into separate files 2017-06-06 16:38:25 +02:00
Johannes Rudolph
3a28584f77 =str gather no stack trace for TcpIdleTimeoutException (#23106) 
Fixes akka/akka-http#1176
 2017-06-06 02:14:45 -07:00