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

22451 commits

This branch
This branch
All branches
Author SHA1 Message Date
Christopher Batey
487d32e16f Support discovering jdk-11 (#25445) 
This is default directory that it is installed at now and the regex
didn't match it
 2018-08-09 18:31:29 +09:00
Arnout Engelen
167c8e3591 Log more details for TCP connection errors (#25450) 
Notably the name of the exception was suppressed, and when you only the
'message' part of a `java.lang.UnknownHostException` it is not very obvious
what is wrong.
 2018-08-09 18:30:52 +09:00
Justin Pihony
b1904325ca Add ClusterSingleton supervision documentation (#25419) 
* Add ClusterSingleton supervision documentation

* Make example code compilable

* Changed snip per comment

* Back to double snip
 2018-08-08 16:24:48 +09:00
Konrad `ktoso` Malawski
7ca7b08694
change to sbt 1.2.1 (#25447) 2018-08-08 14:24:16 +09:00
Jakub Kozłowski
d014877786 Remove "Future is a monad" title (#25437) 
* Add explanation for Future breaking monad laws

* Update futures.md
 2018-08-07 15:14:06 +09:00
Christopher Batey
a0e79a0542 Log exception for association failure (#25438) 
There have been cases where the thrown
NettyTransportExceptionNoStackTrace contains no cause
and a message that doesn't indicate what type of exception has been
thrown when establishing a connection.
 2018-08-06 18:17:58 +09:00
Christopher Batey
131e6d10d6 Separate out Effects and ChainedEffects in typed persistence (#25357) 
* Separate out Effects and ChainedEffects in typed persistence

* Document order of execution for ChainedEffects
* Change stop to a just a ChainedEffect rather than both

Closes #25042
Closes #25041

* ChainedEffect renamed to SideEffect
 2018-08-03 17:15:49 +09:00
Konrad Malawski
729313c66f include mima exclude 2018-08-03 16:31:28 +09:00
Konrad Malawski
a3f50420db make all Take impls use the same implementation (Sink) 2018-08-03 16:31:28 +09:00
Nafer Sanabria
3a92104160 Impl Sink.takeLast operator 
Add documentation

reformatting

Address review comments
 2018-08-03 16:31:28 +09:00
Christopher Batey
2aa333d076 Docs depend on camel test deps to pick up removed camel deps (#25430) 2018-08-03 15:34:04 +09:00
Christopher Batey
59040fadad Add jaxb to camel test classpath (#25417) 
* Add jaxb to camel classpath

* Add activation

* Set camel additioanl libs to be provided

* Doc extra deps

* Add as test dep
 2018-08-02 00:13:03 +09:00
Jean-Loup Roussel-Clouet
cdd177b2c6 Fix a typo in cluster-usage.md (#25424) 2018-08-01 10:24:18 +01:00
Christopher Batey
50ce275848 Upgrade to SBT 1.2.0 (#25415) 2018-08-01 15:30:13 +09:00
Paweł Bartkiewicz
31347a60f4 Fix link to substreams documentation (#25420) 2018-08-01 14:09:14 +09:00
Johan Andrén
85ffc17973 Stack trace changes depending on how throwable is constructed in JDK9+ (#25408) 
This changes the test to not compare stacktraces with equals to avoid
test failures.
 2018-07-31 00:08:10 +09:00
Richard Imaoka
e28535d4cc Add WindowsDiscoverConfig to find JDK (#25368) (#25398) 2018-07-30 23:50:22 +09:00
Christopher Batey
90c1f2f79b Avoid ask to sharding guardian if region already cached (#25407) 2018-07-30 23:48:16 +09:00
Johan Andrén
4ddacb724d
Merge pull request #25380 from davimi/document-stream-source-range-operator 
Document stream source range operator #24933
 2018-07-30 16:11:04 +02:00
Johan Andrén
19124323bb
Merge pull request #25347 from nyukhalov/fix-receive-timeout 
Fixed scheduling and cancelling receive timeout #25340
 2018-07-30 16:09:45 +02:00
Johan Andrén
443f693c05
Merge branch 'master' into document-stream-source-range-operator 2018-07-30 14:32:41 +02:00
Johan Andrén
6d6bd16d41
Added missing lineefeed 2018-07-30 14:23:03 +02:00
Johan Andrén
ca08ca36e2
Turns out "-release 8" isn't enough with Scala 2.11.6 #25330 2018-07-30 13:44:11 +02:00
David Mischke
2737caf8fb use correct Source import 2018-07-27 17:51:00 +02:00
David Mischke
f543f69c93 Merge branch 'master' of https://github.com/akka/akka into document-stream-source-range-operator 2018-07-27 12:35:28 +02:00
Roman Niukhalov
6a1a09de17
Merge branch 'master' into fix-receive-timeout 2018-07-27 13:57:55 +07:00
kenji yoshida
5b3b191bac Remove procedure syntax (#25362) 2018-07-25 13:38:27 +02:00
Seeta Ramayya
50979d599c added getScheduler and getDispatcher methods to ActorSystem #24900 2018-07-25 09:23:03 +02:00
Roman Niukhalov
500f0c2ddc
Merge branch 'master' into fix-receive-timeout 2018-07-24 23:20:39 +07:00
Christopher Batey
d8a47b6700
Switch order of javadsl EventHandler type params (#25354) 
Closes #25188
 2018-07-24 08:47:45 +01:00
Matteo Gazzetta
339fc3d48e Update dependencies and plugins (#25376) 
* Update dependencies
* Update plugins
* Downgrade aeron from 1.10.2 to 1.9.3 due to test failures
 2018-07-24 08:25:29 +02:00
David Mischke
f94733acc6 addressing review comments #24933 2018-07-23 13:07:32 +02:00
Roman Niukhalov
82afb80dcf
Merge branch 'master' into fix-receive-timeout 2018-07-21 23:05:38 +07:00
David Mischke
9885a56f17 Merge branch 'master' of https://github.com/akka/akka into document-stream-source-range-operator 2018-07-21 14:16:58 +02:00
David Mischke
80c0596733 improve Source.range docs #24933 2018-07-21 14:09:32 +02:00
Philippus Baalman
9fae4e2839 Add localized message from cause if message equals null (#25367) 2018-07-20 17:58:52 +09:00
Ikenna Darlington Ogbajie
fb9bb51dc7 Add examples in Scala documentation for Source.fromFuture #24933 (#25374) 
* Add scala documentation for Source.fromFuture #24933
 2018-07-20 07:17:05 +01:00
iyogi
3e698be9ce Add code sample for operator Source.single (#25375) 
* Add code example for Source.single
 2018-07-20 07:15:13 +01:00
Roman Niukhalov
bdd5d408e9
Merge branch 'master' into fix-receive-timeout 2018-07-19 16:06:02 +07:00
Seeta Ramayya
61790d763d Improved logging when node joins itself #25279 2018-07-19 10:26:28 +02:00
Gordon Cheung
1638580339 Added code example for the stream operator map (#25373) 
* Added code example for the stream operator map
 2018-07-19 08:15:17 +01:00
Roman Filonenko
4a8368bfe0 remove unreferenced akka-docs/src/test/*/tutorial_6 (#25363) (#25364) 2018-07-19 15:22:10 +09:00
Chang Liu
862a66ecc7 Add docs and example for akka-stream operator from (#24933) (#25372) 
* Add docs and example for akka-stream operator from (#24933)

* add seperate test class for code example of akka-stream from

* add copyright header
 2018-07-19 13:38:47 +09:00
Konrad `ktoso` Malawski
f4fbbf9312
=typ #24725 disallow deferred behaviors as postStop hooks (#25123) 2018-07-19 10:26:01 +09:00
Giuseppe D'Alessio
578f32d322 Adding combine operator scala example #24933 (#25371) 2018-07-18 18:53:31 +02:00
David Mischke
598b22622d Adding documentation to Source.range method #24933 2018-07-18 18:49:47 +02:00
Roman Niukhalov
76caee2cf4
Merge branch 'master' into fix-receive-timeout 2018-07-18 23:48:52 +07:00
Philippus Baalman
3cf87a1c12 Remove duplicate 'for' in code comments (#25366) 2018-07-19 00:08:51 +09:00
Roman Niukhalov
129ead30d5
Merge branch 'master' into fix-receive-timeout 2018-07-18 21:08:05 +07:00
Roman Filonenko
3b8a448de2 fix broken link in akka-stream docs on ask #25358 (#25360) 2018-07-18 17:35:20 +09:00