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

22379 commits

This branch
This branch
All branches
Author SHA1 Message Date
James Roper
fdcfa9d714 Ensure NPE is always through when VirtualProcessor.onError(null) is invoked (#25311) 
* Ensure NPE is always through when VirtualProcessor.onError(null) is invoked
This fix is similar to #24749, fixing a spec violation bug that was
introduced in #24722.
 2018-07-11 09:27:52 +02:00
Patrik Nordwall
169b81eea5
Merge pull request #25208 from akka/wip-23703-ORSet-ActorRef-patriknw 
Optimized serializer for ORSet[ActorRef], #23703
 2018-07-11 08:59:41 +02:00
Patrik Nordwall
75c8714b21
Merge pull request #25335 from akka/spuriousPrintln 
Remove spurious println
 2018-07-10 21:01:25 +02:00
Patrik Nordwall
b72312d428 Support for rolling upgrade, #23703 2018-07-10 20:54:58 +02:00
Patrik Nordwall
f754705c9c Optimized serializer for ORSet[ActorRef], #23703 
* ORSet[ActorRef] is used by Akka Typed receptionist
* and similar for GSet[ActorRef]

ORSetSerializationBenchmark
 2018-07-10 20:54:51 +02:00
Arnout Engelen
fb906cb603 Remove spurious println 2018-07-10 18:13:36 +02:00
Justin Peel
a05170c419 Check remembered entities before remembering entity (#25271) 
* Check remembered entities before remembering entity

Messages that come through for an entity before StartEntity
has been processed for that entity caused redundant persistence
of the entity.
 2018-07-10 16:24:52 +01:00
Patrik Nordwall
51e0bc2347 Behavior for spawning actors, #25223 (#25273) 
* Behavior for spawning actors, #25223
 2018-07-10 15:43:34 +01:00
Johan Andrén
67e23c44c1 Typed deathpact supervision (#25303) 2018-07-10 15:49:39 +02:00
Patrik Nordwall
62aaae06ca
Merge pull request #25286 from giftig/issue-25285 
Fix Source.actorRef not  completing for Status.Success("ok")
 2018-07-10 13:23:23 +02:00
Rob Moore
ce185c4dfc Source.actorRef not completing on Success (#25285) 
When a Success is received, call onCompleteThenStop instead of just
context.stop; that takes care of the completion logic instead of just
stopping the actor and leaving the stream going.

Add test to ensure the stream materializes on Source.actorRef receiving
Status.Success

Remove tests around stream completion behaviour in response to
PoisonPill - as well as these tests not correctly demonstrating that the
completion was passed on downstream, they describe behaviour which was
previously incidental and is no longer accurate.

Update the docs to reflect that PoisonPill should not be used on the
actor ref as this scenario will necessarily result in bad behaviour as
it will be unable to signal the completion downstream.

Make a few grammar fixes and remove some trailing space while updating the
docs.
 2018-07-09 22:25:32 +01:00
Christopher Batey
836347fe08 Typed persistence: Throw on persist failures, #24479 
* Rather than stop so that users can add their own supervision e.g.
restartWithBackOff
* Only allow back off supervisoir for persistent behaviors
* Handle persist rejections
 2018-07-09 10:57:36 +02:00
Patrik Nordwall
9cecba3455 Composable javadsl CommandHandlerBuilder, #25226 (#25227) 
* Composable javadsl CommandHandlerBuilder, #25226
* CommandHandlerBuilder with stateClass and statePredicate parameters
* CommandHandlerBuilder.orElse
* Remove ActorContext from handler function signatures, can be
  passed in constructor
 2018-07-06 15:35:07 +01:00
Mikko Östlund
46b433b47d Align Java sample DeviceGroupQueryTest with the Scala one #25278 2018-07-03 17:39:12 +02:00
Jimin Hsieh
77c3bee28c Fix broken link (#25304) 2018-07-03 17:30:30 +02:00
Konrad `ktoso` Malawski
29f30a4a78 =clu Accept Welcome message from previous joinSeedNodeProcess #25295 (#25297) 
* =clu Accept Welcome message from previous joinSeedNodeProcess #25295
 2018-07-03 15:22:20 +01:00
Arnout Engelen
bc6cb3b1da Discover Linux java versions with full versions (#25302) 
* Discover Linux java versions with full versions
* Discover java versions from Oracle RPM's
 2018-07-03 15:20:12 +01:00
Roman Filonenko
b7f7af0641 fix formatting spaces in Java samples for akka typed (#25292) 2018-07-03 22:27:26 +09:00
Roman Filonenko
e6d67d8555 fix dependency blocks in documentation (#25240) (#25294) 2018-07-03 14:18:36 +02:00
Christopher Batey
85754e8a2a Harden PersistentBehaviorSpec (#25301) 
As the snapshot is async it might not be ready for the next part of the
test. Use a probe to make sure it is done.

Fixes #25296
 2018-07-03 13:58:10 +02:00
Johan Andrén
29cf96b90c
Concurrency fix for BoundedBlockingQueueSpec #24991 2018-07-03 13:19:04 +02:00
Johan Andrén
6e5efccbd6
Fix failure in typed RecoveryPermitterSpec #25233 2018-07-03 12:10:40 +02:00
Christopher Batey
0f26acd818
Add dep from multi-jvm cluster to multi-jvm cluster-typed (#25299) 2018-07-03 09:03:13 +01:00
Johan Andrén
159ba045cf
Race condition in ManualTimerExampleSpec fixed #24957 2018-07-03 09:36:50 +02:00
Patrik Nordwall
d5d908e1eb
Merge pull request #25290 from chbatey/issue-25288 
Cluster sharding: Set waiting for state timeout for tests
 2018-07-02 20:23:20 +02:00
Patrik Nordwall
f0b0183ef3
Merge pull request #25291 from johanandren/wip-24728-cluster-api-spec-fail-johanandren 
Don't trigger graceful leave in typed ClusterApiSpec
 2018-07-02 20:14:56 +02:00
Arnout Engelen
8ba48c0adc
Compile with jdk9, targeting jdk8 (#24711) 2018-07-02 16:38:07 +02:00
Johan Andrén
75f044a0d0 Don't trigger graceful leave #24728 2018-07-02 15:57:36 +02:00
Roman Filonenko
e94d011cbd populate Creating Actors section in the akka typed documentation (#25218) (#25236) 
* populate Creating Actors section in the akka typed documentation (#25218)
 2018-07-02 13:31:39 +01:00
Christopher Batey
ee7e699d23 Cluster sharding: Set waiting for state timeout for tests 
Default is 5s which means if the first Read is lost and
a test ddata have any secondary nodes to query it'll
timeout waiting to get the state.

E.g. read being ignored due to loading durable state then
never gets retries
 2018-07-02 12:50:29 +01:00
Patrik Nordwall
02f6899952 example for Streams log operator (#25283) 
* and added all log levels in Attributes for convenient single access point
 2018-06-30 12:10:10 +09:00
Matt Kohl
33904de972 Documentation fix (#25282) 2018-06-29 13:35:24 +02:00
Christopher Batey
1bc8b32b3c
Merge pull request #25214 from chbatey/wip-async-dns-chbatey 
Async DNS with SRV records
 2018-06-29 07:43:23 +01:00
Christopher Batey
2dad7a4c08 Complete async DNS that uses the name servers top to botom 2018-06-28 15:20:23 +01:00
Konrad `ktoso` Malawski
d623593bc2 Async DNS largely inspired by https://github.com/ilya-epifanov/akka-dns 2018-06-28 15:19:27 +01:00
Martynas Mickevičius
975d2d8371
Merge pull request #25234 from 2m/wip-assert-all-stages-public-2m 
Make assertAllStagesStopped a public API
 2018-06-27 12:00:03 +03:00
Martynas Mickevičius
766944a592
Expose assertAllStagesStopped 2018-06-27 10:34:32 +03:00
Nicolas Vollmar
28746a4cfe Ignore possible state change while waiting for removal #25274 2018-06-27 09:06:32 +02:00
Patrik Nordwall
9075480747
Merge pull request #25275 from akka/wip-doc-reword-patriknw 
reword the Multi-DC Persistence reference
 2018-06-27 08:13:02 +02:00
Roman Filonenko
4d31d7ce49 log address having heartbeat problems in PhiAccrualFailureDetector (#24701) (#25237) 
* log address having heartbeat problems in PhiAccrualFailureDetector (#24701)

* update binary compatibility comments
 2018-06-27 07:19:36 +02:00
Johan Andrén
6a6b5822b1 Include compiling multi-jvm tests in PR validation (#25245) 2018-06-27 07:04:05 +02:00
Patrik Nordwall
3e5b2c3f89 reword the Multi-DC Persistence reference 2018-06-26 16:57:37 +02:00
Lukasz Stefaniak
b8230a38b7 Optimize JsonObjectParser.isWhitespace by replacing Set.contains with match using table switch (#25260) 2018-06-26 16:44:28 +02:00
Roman Filonenko
427124a531 increase threshold to publish heartbeat interval warnings in PhiAccrualFailureDetector (#25253) (#25259) 2018-06-26 16:14:25 +02:00
Guy Youansi
a4951e0ce7 Java time duration support for javadsl #24646 
java.time.Duration support in all jdocs java file, the persistence module and the distributed-data
 2018-06-26 15:41:30 +02:00
Johan Andrén
ced08fcb57 Return of the old docs banner (#25254) 2018-06-26 14:09:28 +02:00
Patrik Nordwall
072627380b Optimize mapAsync(1) (#25185) 
* by using mapAsyncUnordered for that case
 2018-06-26 12:36:41 +02:00
Richard Imaoka
d8085bb424 doc Replace the word graph by operator in stream doc (#25219) 2018-06-26 11:12:05 +02:00
Christopher Batey
4bee6aa833
Typed FSM docs page (#25266) 
* Typed FSM docs page

Show how the example for untyped FSM can be ported to typed
 2018-06-26 06:56:50 +01:00
Johan Andrén
2b6997b7a0
Typed: Un-nest supervision that overlaps #25128 2018-06-25 20:53:06 +02:00