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

20634 commits

This branch
This branch
All branches
Author SHA1 Message Date
Martynas Mickevičius
ffcb83511c Use Example Code Service for samples 2017-03-31 13:52:05 +03:00
Qing Wei, Lim
d3de9d40cd Add docs for circuit breaker new feature #22596 2017-03-30 16:51:51 +02:00
Thomas Alton
626d07edca Schedule timer for remaining delayed elements #22416 2017-03-30 16:27:01 +02:00
Patrik Nordwall
2714dca5e1 Merge pull request #22656 from akka/wip-22655-delta-None-patriknw 
Handle delta None correctly, #22655
 2017-03-30 15:45:13 +02:00
Sebastian Harko
c9c59dd211 Serialization Docs: Better intro to custom serializer section (#22653) 2017-03-30 13:36:09 +02:00
Patrik Nordwall
5293666a30 Use full state for the ORSet and ORMap removals until #22648 is fixed 
* some tests disabled, search for
  "FIXME use full state for removals, until issue #22648 is fixed"
  to find them
 2017-03-30 13:26:35 +02:00
Patrik Nordwall
dc070e4e1c fix wrong log in receiveDeltaPropagation 2017-03-30 13:02:10 +02:00
Richard Imaoka
e82d2c2817 Update deferAsync doc #20873 2017-03-30 11:34:09 +02:00
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
9855e2896f Handle delta None correctly, #22655 
When a DeltaReplicatedData returns None from delta it must still be
treated as a delta that increase the version counter in DeltaPropagationSelector.
Otherwise a later delta might be applied before the full state gossip is received
and thereby violating RequiresCausalDeliveryOfDeltas.
 2017-03-30 08:12:03 +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