Lukas Rytz
aa03e8b089
Update Scala to 3.0.0 final, sbt to 1.5.2 ( #30248 )
...
Also: Migrate to sbt slash syntax
2021-05-25 12:50:51 +02:00
Yury Gribkov
49759617ab
Add BoundaryEvent cancellation hook for telemetry ( #30246 )
2021-05-20 18:10:44 +02:00
Andrei Arlou
657386488d
Fix test ActorCreationTest.testWrongAnonymousInPlaceCreator ( #30236 )
...
* Fix test ActorCreationTest.testWrongAnonymousInPlaceCreator - added non-static check for Creator (#30220 )
* fix spec test
2021-05-19 21:06:56 +02:00
Arnout Engelen
79b48ca354
Remove SourceModule/SinkModule newInstance ( #30244 )
...
* Remove SourceModule/SinkModule newInstance
AFAICS it's not public API and not called anywhere
Extracted from #30223
* mima excludes
2021-05-19 20:51:30 +02:00
Xiaoguang Zhang
a19e73a253
lease settings support for typed cluster singleton ( #30209 )
2021-05-19 11:05:40 +02:00
Johannes Rudolph
18e78816c3
stream: reuse maxBytesPerChunk buffer for inflate / gunzip ( #30239 )
...
Before, for every round of `parse` a new buffer was allocated that was then
copied again by `ByteString.fromArray`. This effectively more than doubled
the allocation rate while inflating. For bulk data like expected for
compressed data this can make a big difference in throughput.
The slight downside of keeping the buffer is that the stage now uses more memory
by default even while idle. deflate/gzip's window is 64kb which happens to be also the
default `maxBytesPerChunk` setting. It is therefore expected that the additional buffer will
less than double the existing memory footprint while dividing the allocation rate
by more than two which seems like a good trade-off.
2021-05-17 16:08:26 +02:00
Patrik Nordwall
2dde4b6b51
Merge pull request #30211 from johanandren/wip-remove-leveldbjournalnative-perf-spec
...
Delete CI-sensitive LevelDB perf spec
2021-05-14 16:18:00 +02:00
Patrik Nordwall
877c4ee29d
Merge pull request #30216 from nivox/fix-hubspec-test
...
Fixed race condition in MergeHub draining test: 30207
2021-05-14 16:15:02 +02:00
Muskan Gupta
dd8b514e89
Add Sink.asPublisher example and update doc ( #30105 )
...
Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>
2021-05-12 21:16:41 +02:00
Patrik Nordwall
240378f062
Merge pull request #30233 from Captain1653/use-standart-charsets
...
Use StandardCharsets.UTF-8 in SerializationDocTest
2021-05-12 13:10:51 +02:00
Patrik Nordwall
245527cacb
Merge pull request #30235 from toshetah/patch-1
...
Fix Broadcast examples, as they currently fail.
2021-05-12 13:09:14 +02:00
Tomer Shetah
82fc6c0e68
Fix Broadcast examples, as they currently fail.
...
Use different outputs for broadcast
2021-05-11 15:29:28 +03:00
Captain1653
0ee9532306
Use StandardCharsets.UTF-8 in SerializationDocTest
2021-05-10 18:00:53 +03:00
Andrei Arlou
f568d4d4f9
Remove usage of Java assert in tests ( #30220 ) ( #30227 )
2021-05-07 21:27:39 +02:00
Seeta Ramayya
174c725ef8
fixed typo ( #30218 )
2021-05-05 13:20:10 +02:00
Andrei Arlou
1a36631dbb
Use assertThrows in classes ActorCreationTest and OutputStreamSinkTest ( #30165 )
2021-05-05 10:45:37 +02:00
Jens Neumaier
73d74dfc69
Resolve missing internal state update in EventSourcedRememberEntities… ( #30217 )
2021-05-04 14:59:24 +02:00
Andrea Zito
9fbc796515
Fixed race condition in MergeHub draining test: 30207
2021-05-03 17:08:52 +02:00
Johan Andrén
958db9cc68
Delete CI-sensitive LevelDB perf spec
2021-05-03 14:04:31 +02:00
Scala Steward
43d97e90c0
Update sbt-bill-of-materials to 1.0.2 ( #30183 )
2021-05-03 12:05:51 +02:00
Scala Steward
ea22157859
Update sbt-scalafix to 0.9.27 ( #30181 )
2021-05-03 12:05:28 +02:00
Andrei Arlou
b3edd0eeac
Refactor GraphDslTest and TcpTest ( #30160 )
2021-05-03 11:25:41 +02:00
franciscolopezsancho
4f5e01376d
avoiding fixed persistenceId on example ( #30203 )
2021-05-03 11:06:00 +02:00
Patrik Nordwall
5de4942485
Merge pull request #30206 from jrudolph/avoid-assumptions-about-other-subproject
...
build: more reliable reference to protobuf jar
2021-05-03 11:01:11 +02:00
Scala Steward
ae55f262ed
Update sbt-dotty to 0.5.4 ( #30180 )
2021-05-03 10:46:53 +02:00
Dave Kichler
f8770609ca
Documentation: Adding section for Projections to the Modules summary… ( #30175 )
...
* Documentation: Adding section for Projections to the Modules summary page #29710
* Added Projections entry in the module summary index.
* Added Projections section with brief description and dependency reference.
* Documentation: Cross-links between core modules guide and other modules page #29710
* Removed HTTP section from core modules page (redundant with section in other modules page)
* Added link to other modules page on the core modules guide
* Added link to the core modules guide from the other modules page.
* Documentation: Adding sections for Alpakka and gRPC to modules guide. Adding original HTTP section back in as well. #29710
2021-05-03 10:32:11 +02:00
franciscolopezsancho
4f278e5eaa
avoiding the superposing of the buttons and the code ( #30210 )
2021-05-03 10:28:31 +02:00
Johannes Rudolph
2b567706cb
build: more reliable reference to protobuf jar
...
This avoids problems when the naming convention changes and also makes
sure the file has actually been generated.
2021-04-29 12:02:01 +02:00
Muskan Gupta
099e20ec6d
add example to the doc of combine operator ( #30194 )
2021-04-29 08:37:14 +02:00
Renato Cavalcanti
571aa85a36
Add settings to use context.log for internal ESB logging ( #30202 )
...
* add settings to use context.log for internal ESB logging
* only force ctx.log if needed
* removed hardcoded value
* fix compilation
2021-04-27 15:22:53 +02:00
Sergey Morgunov
fc4e84a322
#30191 - Actualization of docs for "Resumable projections" ( #30197 )
2021-04-22 17:27:25 +02:00
Andrei Arlou
e74f77236c
Change jdk version for javadoc generation in CONTRIBUTING.md ( #30196 )
2021-04-20 13:05:45 +02:00
Nicolas Vollmar
c04f6ca5a1
Removes unnecessary postStop #30071 ( #30187 )
...
* Removes unnecessary postStop #30071
* Adds test for future source with substream #30071
2021-04-20 10:36:30 +02:00
Dave Kichler
46b63e369e
Clarify documentation for persisting multiple events in the context o… ( #30169 )
...
* Add details to event handler section clarifying how multiple events are handled
* Add details to side-effect section to clarify how state passed to the side-effect method is an accumulation of state changes from all persisted events
2021-04-19 17:33:10 +02:00
Levi Ramsey
d40ab055f5
Unwatch before watch in typed Supervision ( #30172 )
2021-04-15 17:22:29 +02:00
Arnout Engelen
ba06b19835
Pin jackson-databind to 2.11 ( #30185 )
2021-04-13 14:14:49 +02:00
Johan Andrén
1f056aa1ef
Accidentally snuck in wrong patch version excludes for SBR internal change ( #30178 )
2021-04-13 10:42:48 +02:00
Renato Cavalcanti
dcb73c0200
Simplified reverse in lease majority ( #30155 )
2021-04-09 14:02:35 +02:00
Johan Andrén
0a226eb3ea
Extra catch-ignore for source attributes in case not possible #30138
2021-04-09 14:01:49 +02:00
Johan Andrén
031886a7b3
MiMa latest patch update to 2.6.14 ( #30173 )
2021-04-08 14:59:08 +02:00
Andrea Zito
318b9614a3
Add draining control support to MergeHub #30057
...
- MergeHub materialization now produces a DrainingControl object alongside the Sink
- The DrainingControl can be invoked to initiate the draining procedure
- No new producers can be connected to the Hub
- The Hub is completed as soon as all the currently connected producers complete
2021-04-07 11:34:59 +02:00
Christopher Batey
99ec6f9d82
Document persist failure supervision for ESBs #30062
2021-04-07 11:33:08 +02:00
Eugene Apollonsky
71225b4f2b
Avoid TaskQueue allocations in Scheduler #30093
2021-04-06 15:21:11 +02:00
Arman Bilge
f155ff12fa
Remove async boundary note in Source.actorRef docs ( #30162 )
2021-04-06 12:23:02 +02:00
Arman Bilge
40f1edf89f
Preserve attributes of inner stages when using {Source,Flow,Sink}.fromMaterializer ( #30142 )
2021-04-02 16:04:07 +02:00
franciscolopezsancho
fb432b3d8a
Typed consistent hashing example ( #30036 )
...
Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>
2021-04-01 09:31:42 +02:00
archeuclid
55ec18962c
Change Effects() to Effect() ( #30157 )
2021-04-01 08:55:56 +02:00
Andrei Arlou
6f3ea12282
Remove unnecessary modifiers from FI.java ( #30119 )
2021-04-01 08:00:17 +02:00
Jorge Gomez
914a94e405
ActorSinkWithAckExample Ack message ( #30127 )
...
Using the example does not work in Java, because it seems that `Sink` compares by equality, no by class.
2021-03-31 09:14:12 +02:00
Scala Steward
4ff77b813e
Update junit to 4.13.2 ( #30099 )
2021-03-30 23:29:37 +02:00
