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

23780 commits

This branch
This branch
All branches
Author SHA1 Message Date
Johannes Rudolph
21adbcfa34
actor: ignore more messages while TcpConnection is shutting down 
Otherwise, there will be noisy warnings in the log for messages that
carry `DeadLetterSupression` like all the `CloseCommands`.
 2019-07-31 13:36:58 +02:00
Christopher Batey
e55ac350c3
Fix race in AkkaProtocolSpec (#27431) 
The heartbeat happens after the send associate in
AkkaProtocolTransport so test can't assume the heartbeat
has happened.

Fixes #26974
 2019-07-31 09:05:58 +01:00
Helena Edelson
914466c8c2
Fixed akka-stream-tests-tck warnings (#27436) 2019-07-30 08:33:48 -07:00
Helena Edelson
01f5698677
Added GPG and release script prerequisite setup steps explicitly to release doc (#27417) 2019-07-30 07:55:33 -07:00
Helena Edelson
737fedcb91
Review suggestions tested and added, stepped on the merge gas with two approvals but suggestions lingering #27424 (#27433) 2019-07-30 06:30:57 -07:00
Helena Edelson
5f35c2326e
Cleaned up ShardsQueryResult and added region shards query timeout for failure context in logging. (#27427) 2019-07-30 05:33:37 -07:00
Christopher Batey
89e269d5d8 Remove catchall silents from prod code (#27432) 
* WIP

* Remove catch all silent annocations from prod code
 2019-07-30 11:12:23 +02:00
Arnout Engelen
e898197bdd Add 'core' and 'dumps' to gitignore (#27423) 
'core' is sometimes left behind by graphviz, and a 'dumps' directory
is sometimes left behind when running with jdk11 and graal.
 2019-07-30 08:11:05 +01:00
Arnout Engelen
80a920da52 Fix warnings in akka-actor-typed-tests (#27424) 2019-07-29 13:52:07 -07:00
Dale Wijnand
c4417d1c59 Reword the "private messages" typed style docs (#27392) 
Use Message/Command/Event as a better example, as the
PrivateCommand/Command example seemed to go out of its way to look
like an unattractive implementation strategy.

Oh, and touch up the "Partial versus total Function" section below too.
 2019-07-29 12:00:27 +02:00
Mohamed Ali Bannour
56f3a6b126 Update example documentation of retry. (#27403) 2019-07-26 13:56:51 -07:00
Christopher Batey
e188b1f653 Migration guide for Persistent FSM to typed persistence (#27336) 2019-07-26 10:01:11 +02:00
Helena Edelson
3534a0b977
Productionize: GetShardRegionStats returns empty shard set on ask timeout (#27395) 2019-07-25 08:00:34 -07:00
Johannes Rudolph
051ff07ca2 Provide more helpful message when synchronous testing ActorRef is used for asking (#27414) 2019-07-25 16:42:24 +02:00
Christopher Batey
4f6cccc4d8 Fix stashing of commands when snapshot is in progress (#27389) 
* Fix stashing of commands when snapshot is in progress

Fixes #27381

* Naming
 2019-07-25 16:32:57 +02:00
Arnout Engelen
e5e2922b0f
OutputStreamGraphStage follow-up fixes (#27412) 
To https://github.com/akka/akka/pull/26827
 2019-07-25 14:58:43 +02:00
Johannes Rudolph
e39bbb34b8
Deemphasize CallingThreadDispatcher in the docs (#27401) 
Deemphasize CallingThreadDispatcher in the docs
 2019-07-25 14:26:38 +02:00
Helena Edelson
96abaf2168 Add clarification to doc on cluster cross boundary use of DeathWatch (#27385) 
* Add clarification to doc on cluster cross boundary use of DeathWatch #27376

* Clarrified reasoning and behavior update, and updated warning config name to same convention.
 2019-07-25 14:12:57 +02:00
Christopher Batey
625eb7b913 Re-write output stream subscriber as graph stage (#26827) 2019-07-25 13:51:47 +02:00
Christopher Batey
09838a71e5 Remove source/sink fromPublisher/fromSubscriber (#27288) 
* Remove source/sink fromPublisher/fromSubscriber

Refs #26187

* mima
 2019-07-25 13:16:30 +02:00
Helena Edelson
ba2384893f Expand on rolling update recommendations, best practices (#27382) 2019-07-25 11:53:16 +02:00
Yury Gribkov
a53f1a8101 Change the onWriteRejected and onWriteFailed signature to pass PersistentRepr for context propagation. (#27408) 2019-07-25 10:26:24 +01:00
kenji yoshida
94857fd4e1 update mima url (#27407) 2019-07-24 14:22:10 +02:00
Dale Wijnand
5997f516de Reword the "Where to define messages" style docs (#27393) 2019-07-24 13:26:43 +02:00
Kun Song
38be540467 Use min of numberOfMessages and buffer size when unstash. (#27398) 2019-07-24 12:32:22 +02:00
Christopher Batey
7cc7d86971
Instructions for generating protobuf (#27402) 
* Instructions for generating protobuf

* Update CONTRIBUTING.md

Co-Authored-By: Arnout Engelen <github@bzzt.net>
 2019-07-24 10:25:53 +01:00
Arnout Engelen
6d4fbfc43d Loosen expectation of TlsTcpWithHostnameVerificationSpec (#27394) (#27396) 2019-07-24 08:34:25 +01:00
Arnout Engelen
ccd2c9aff6 Include version error in the docs (#27365) 
So the relevant section will show up in google
 2019-07-24 07:47:37 +01:00
Arnout Engelen
c4d4dd3875 Persistence typed context (#27404) 
* Add context parameters to persistence typed
* Add hooks to capture event-written
 2019-07-23 18:47:25 -07:00
Johannes Rudolph
743c542e18 streams: clarify how to complete a Source.actorRef in Scaladocs and docs (#27325) 
* streams: clarify how to complete a Source.actorRef in Scaladocs and docs
 2019-07-23 19:17:11 +02:00
Christopher Batey
6c416c2818 User serializer for protobuf3 (#27362) 
* User serializer for protobuf3
 2019-07-23 16:22:07 +02:00
kerr
d4dcbee4c9 Use a dedicated mismatching indicator instead of null for WidenInterceptor. (#27292) 2019-07-23 15:58:03 +02:00
Arnout Engelen
df57d42782
Deemphasize CallingThreadDispatcher in the docs (#27387) 2019-07-23 10:09:59 +02:00
Kun Song
5e68cd0297 Fix a typo in Stash document (#27399) 2019-07-23 09:35:31 +02:00
Dale Wijnand
f2eec1106d Reword the "ask versus ?" typed style docs (#27390) 2019-07-23 09:25:34 +02:00
Dale Wijnand
fb653cc336 Fix some grammar in the typed style guide (#27388) 
Also, use English ("for example") rather than Latin ("e.g.") in docs.
 2019-07-22 15:25:01 +02:00
Christopher Batey
69fd98a39d Fix SurviveNetworkInstabilitySpec (#27383) 2019-07-19 07:27:08 -07:00
jeremie-seguin
950ec71294 fix typo in stream doc (#27379) 2019-07-19 09:18:08 +02:00
Johan Andrén
03b8c543fc Serialization support for wrapped stream refs (#27353) 2019-07-16 10:11:33 -07:00
kerr
cdd7976c26 Don't use pattern matching to generate less bytecode. (#27293) 2019-07-16 08:30:54 -07:00
Arnout Engelen
c3e8a968d9
Test hostname verification (#27355) 2019-07-16 15:32:50 +02:00
Patrik Nordwall
10c2b0714a reduce message sizes for Gossip and DeltaPropagation in ddata, #27175 (#27176) 2019-07-16 14:22:16 +02:00
Johan Andrén
2626f17747
Select mailbox in Akka typed actors #27124 2019-07-16 13:52:23 +02:00
Johan Andrén
d03294d359
Align SpawnProtocol with style guide #27318 2019-07-16 11:36:12 +02:00
James Roper
511356177d Added actor termination coordinated shutdown task #27089 
A convenience method that allows creating a
shutdown task by sending a message to an actor, and watching for its
termination.
 2019-07-16 10:56:48 +02:00
Arnout Engelen
d3170a56ea Add fluent API for 2-stream merging (#27020) 
* fluent API for 2-stream mergeLatest, mergePreferred and mergePrioritized
* Add javadocs and 'eagerClose' paramter to 'mergeLatest'
* fluent API's for
 2019-07-16 10:54:18 +02:00
Philippus Baalman
0f7dbf6fcb Replace link to scalariform with link to scalafmt (#27239) 2019-07-15 15:51:32 +02:00
Johan Andrén
f0e42d2b9c
Cluster aware routers for typed #26355 2019-07-15 15:25:00 +02:00
Christopher Batey
d2f5d2daa3 Allow java serialization for TypedActorRemoteDeploySpec (#27354) 
* Allow java serialization for TypedActorRemoteDeploySpec

* Also delete ignore for 2.12 annotation
 2019-07-15 14:00:34 +02:00
rohitkumbhar
50b63464fa Hostname verification should be done by the client only (#26906) 
Setting the endpoint identification algorithm to HTTPS on the server engine
forces the client to preset a certificate that contains the server name. This
is rather unlikely and it fails TLS handshake today

This change will allow hostname verification to be done by the client only
 2019-07-15 13:43:50 +02:00