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

20625 commits

This branch
This branch
All branches
Author SHA1 Message Date
Sebastian Harko
aa5a27182e Serialization Docs: add info about adding a logger (#22618) 2017-03-30 11:31:18 +02:00
Pepe García
16014c4d1f fix compilation in scaladoc code for TestFSMRef #22625 2017-03-30 10:56:02 +02:00
Patrik Nordwall
24ddc8f381 Merge pull request #22634 from gosubpl/wip/22350-coalescing-deltas 
delta-aggregation in the ORMap deltas (#22633)
 2017-03-28 20:28:21 +02:00
Konrad `ktoso` Malawski
5eb1651438 =str #22358 enable test and cleanup FutureFlatten source 2017-03-28 12:55:12 +03:00
ortigali
d06640eff9 failed: BalancingSpec #22040 2017-03-28 12:29:18 +03:00
ortigali
8cf563c066 Handle IncompatibleClassChangeError by writing "fix your akka version" (#22628) 
* Handle AbstractMethodError etc in the root guardian by writing "fix your akka version" #21891

* print error message to System.err #21891

* remove line endings to work on Windows also #21891
 2017-03-28 10:47:44 +02:00
Patrik Nordwall
2bdb6eccd9 Merge pull request #22603 from hepin1989/master 
= str #22602 short path for Source.fromFuture and fromFutureSource an…
 2017-03-28 10:14:35 +02:00
gosubpl
7c42627ea9 delta-aggregation in the ORMap deltas (#22633) 2017-03-27 23:51:09 +02:00
Troxid
789626c043 =doc Fix broken headers (#22637) 2017-03-27 18:55:14 +02:00
虎鸣
e9694edaab =str #22602 short path for Source.fromFuture and fromFutureSource and their alias 2017-03-28 00:39:40 +08:00
Björn Antonsson
f8b4fb55ca Remove use of deprecated Scala features #22581 2017-03-27 19:05:54 +03:00
Johannes Rudolph
7b9342e324 =str #22124 fix failing TlsSpec "certificate check" 
It seems the reason for the failure was that `Sink.head` canceled the
server binding before or while the first connection was being established
and handled. Using `mapAsync` instead will prevent that the binding is
canceled before the inner flow has finished.
 2017-03-24 16:46:45 +02:00
Sebastian Harko
9abb73069c Serialization Docs: better intro (#22624) 2017-03-24 16:26:50 +02:00
Sebastian Harko
ecbcc56f28 =doc Serialization Docs: section on verification (#22616) 
* improve docs for serialization a bit

* fix wording in docs for serialization
 2017-03-23 16:58:09 +01:00
Patrik Nordwall
b4dbf84da8 Merge pull request #22619 from gosubpl/wip/22606-fix-duplicate-delta-in-ormap 
fix ORMap duplicated delta propagation (#22606)
 2017-03-23 16:51:24 +01:00
Sebastian Harko
b28ad073a4 -doc remove dead library ref from documentation (#22617) 2017-03-23 11:09:36 +01:00
gosubpl
2caef783dc fix ORMap duplicated delta propagation (#22606) 2017-03-23 10:49:42 +01:00
Patrik Nordwall
2d006558ab Merge pull request #22607 from akka/wip-22604-ser-delta-patriknw 
fix serialization of delta ops, #22604
 2017-03-21 17:52:55 +02:00
Andrii Lashchenko
394f1e4209 Fix umlaut in akka-doc #22611 (#22612) 2017-03-21 14:38:11 +02:00
gosubpl
dfbf50538e fixed serialization of RemoveKey 2017-03-21 09:43:33 +02:00
Patrik Nordwall
cc7065601a fix serialization of delta ops, #22604 2017-03-21 09:43:27 +02:00
Patrik Nordwall
45f4727625 Merge pull request #22594 from johanandren/wip-22541-update-docs-johanandren 
Java style accessors for AbstractFSM
 2017-03-17 13:18:20 +01:00
Patrik Nordwall
389dcba314 Merge pull request #22595 from akka/wip-spawnAdapter-2.12-patriknw 
rename spawnAdapter due to Scala 2.12 compilation error
 2017-03-17 13:17:53 +01:00
Patrik Nordwall
191bd0fe41 =str #22584 make subfusing work if diff materialize() is called 
Also: removed unecessary method with wrong name, #22350
 2017-03-17 12:42:13 +01:00
Patrik Nordwall
d871b63990 rename spawnAdapter due to Scala 2.12 compilation error 
* and make scaladoc happy ForkJoinPool.ForkJoinWorkerThreadFactory
 2017-03-17 11:27:13 +01:00
Patrik Nordwall
ef3b0f7444 Merge pull request #22586 from akka/wip-22295-circuit-breaker-improvement2-patriknw 
22295 Allow user define what is failure in terms on circuit breaker
 2017-03-17 10:28:19 +01:00
Patrik Nordwall
edee6ae544 Merge pull request #22508 from gosubpl/wip/22350-delta-crdt-orset-friends 
ORMap and friends are delta-CRDTs (#22350)
 2017-03-17 10:27:52 +01:00
Johan Andrén
07e88300bc Java style accessors for AbstractFSM #22592 2017-03-17 10:26:37 +01:00
ortigali
363ca39f52 AbstractPersistentFSM should have getContext, getSelf, getSender #22541 2017-03-17 09:27:15 +01:00
gosubpl
1f2ef60174 ORMap and friends have deltas (#22350) 2017-03-17 02:47:50 +01:00
Patrik Nordwall
cdc1eddc3b Merge pull request #22577 from akka/wip-typed-IntroSpec-patriknw 
add Akka Typed Java API #22293
 2017-03-16 22:28:22 +01:00
Patrik Nordwall
bece5e3fd0 Merge pull request #22560 from akka/wip-18262-fjp-patriknw 
Embed FJP
 2017-03-16 22:25:39 +01:00
Patrik Nordwall
f485be2bf5 Let typed Stateful optionally handle signals also, #22293 
* and thereby no need for MessageOrSignal
 2017-03-16 20:55:50 +01:00
Patrik Nordwall
ef62a88072 mima filters and note in migration guide 2017-03-16 20:49:01 +01:00
Patrik Nordwall
0904da1a85 Make FJP SPINS configurable with System.property, default 256 2017-03-16 20:49:01 +01:00
Patrik Nordwall
7e3376eb5f scala 2.11 FJP 2017-03-16 20:49:01 +01:00
Patrik Nordwall
569175ac62 Improve ForkJoinActorBenchmark 
* more messages in flight

* additional cleanup
 2017-03-16 20:48:55 +01:00
Johan Andrén
57bce6ad1f Benchmark for actor throughput with FJP #18262 
1-to-1 actor per core bench, avoiding to spend time in string equals
 2017-03-16 20:45:10 +01:00
Patrik Nordwall
c3c058b6bb Merge pull request #22360 from johanandren/wip-21363-future-source-last-bit-johanandren 
Source that flattens a future source and keeps mat val
 2017-03-16 20:36:05 +01:00
Patrik Nordwall
6274af63dd Merge pull request #22580 from johanandren/wip-missed-java-doc-path-updates-johanandren 
Updates to paths in the Java docs missed in #22413
 2017-03-16 20:33:30 +01:00
Patrik Nordwall
22dedd1ffa Merge pull request #22565 from johanandren/wip-fix-mat-dep-warning-johanandren 
A few warnings fixed
 2017-03-16 20:33:07 +01:00
Qingwei
c879c03679 22295 Allow user define what is failure in terms on circuit breaker 
Revert all unnecessary style changes

Add api for java

Make exceptionsAsFailure function private

Exclude changed method api for binary compatibility check

- The changes expand the api by overload, thus is backward compatible
 2017-03-16 20:31:38 +01:00
Maciej Ciołek
f60710b58f Handlers for circuit breaker (#22244) 
* Adding call handlers to CircuitBreaker

* Improvements to docs

* Make System.nanoTIme called as latest as it is possible

* Java naming conversion changed, previous Java methods marked as deprecated

* Code reformated
 2017-03-16 20:05:16 +01:00
Martynas Mickevičius
2a9c0370e0 Add @InternalApi annotations and private markers on internal apis (#22563) 
* #22506 Mark materializer extension as @InternalApi

* #22506 Added missing annotations on internal apis in the fusing package

* #22506 Missing annotations in io package

* #22506 Add internal api annotations in impl package

* #22563 more hiding of the classes in the impl package

* #22563 Formatting fixes

* #22506 Fix private access in stream tcl tests
 2017-03-16 20:04:07 +01:00
Hawstein
6434cbe868 Re-implement javadsl testkit (#22240) 
* re-implement javadsl testkit

* fix mima problem

* rebase master

* move ImplicitSender/DefaultTimeout to scaladsl

* undo the change of moving scala api

* fix return type and add doc

* resolve conflicts and add more comments
 2017-03-16 20:02:47 +01:00
Johan Andrén
3643f18ded Protobuf serializers for remote deployment #22332 2017-03-16 15:12:35 +01:00
Johan Andrén
ad0fd1320f Updates to paths in the Java docs missed in #22413 2017-03-16 15:11:02 +01:00
Patrik Nordwall
b2b4f64d97 convert typed IntroSpec to new API, #22293 2017-03-16 14:51:19 +01:00
Patrik Nordwall
3e4f44765c Merge pull request #22574 from bantonsson/fix-indentation-master 
Fix indentation diffs
 2017-03-16 14:12:29 +01:00
Roland Kuhn
4368bed37a add Akka Typed Java API #22293 
... and matching Scala DSL, to replace the old ScalaDSl._ object.
 2017-03-16 11:52:30 +01:00