Commit graph

24153 commits

Author SHA1 Message Date
Patrik Nordwall
13f4d0ffa2 Use ActorSystem's ThreadFactory for the Aeron threads, #27603 (#27665) 2019-09-16 20:19:46 -07:00
Helena Edelson
8a25f186fa Cluster sharding with remember entities (persistence) must setup shared journal (#27692)
* ClusterShardingRememberEntitiesSpec: Cluster sharding with remember entities (persistence) must setup shared journal #27548 - fixed original problem but may have uncovered another in the process.
2019-09-16 14:00:27 +02:00
Patrik Nordwall
bbf9e7c617
Merge pull request #27670 from akka/wip-24955-multi-dc-events-patriknw
Avoid publication of duplicate UnreachableDataCenter, #24955
2019-09-16 13:59:17 +02:00
Johan Andrén
47a0cca919
Fixes to one of the tests in FlowGroupBySpec (#27675) 2019-09-16 11:59:00 +02:00
Mahmut Bulut
bc590af56f Fix stream detached exception variable naming (#27711) 2019-09-16 09:55:06 +02:00
Patrik Nordwall
223f84e8b9 doc: stylish distributed-data.md, #24717
* move to docs package
* style changes
2019-09-13 17:03:33 +02:00
Patrik Nordwall
c30aacf991
Merge pull request #27682 from scala-steward/update/scalafmt-core-2.0.1
Update scalafmt-core to 2.0.1
2019-09-13 16:49:42 +02:00
Johan Andrén
83606f630a Upgrade to akka-paradox 0.24 with search box transparency fix (#27686) 2019-09-13 10:35:00 +02:00
Johan Andrén
672a629127
Added ttl configs for AsynchDnsResolve #27694 (#27695) 2019-09-13 09:15:13 +02:00
Patrik Nordwall
24d7c8471f wait for async excess events when occurrences 0
* otherwise withOccurrences(0) testing is typically not testing
  anything since logging is typically async from some actor
* but don't want to slow down by always waiting when occurrences > 0
2019-09-13 08:39:44 +02:00
Roman Filonenko
489f7c2288 fix JsonFraming to accept multiple top-level arrays (#26098) (#26099) 2019-09-12 17:42:22 -07:00
Helena Edelson
4c894d628f Adding back jcenter repo accidentally removed in consolidation #27657 (#27698) 2019-09-12 17:52:43 +02:00
Patrik Nordwall
89eab3541c
Merge pull request #27511 from akka/wip-27371-DataDeleted-patriknw
API changes related to DataDeleted, #27371
2019-09-11 16:28:17 +02:00
Arnout Engelen
e6859253e5 Update to MiMa 0.6.0 (#27558) 2019-09-11 11:28:12 +02:00
Johannes Rudolph
b84624fc70
Update to paradox 0.6.5 (#27664)
Update to paradox 0.6.5
2019-09-11 10:57:37 +02:00
Scala Steward
e17e66b21b
Update scalafmt-core to 2.0.1 2019-09-11 00:46:47 +02:00
Patrik Nordwall
1d09d2725b API changes related to DataDeleted, #27371
* The reason for this change is that `DataDeleted` didn't extend the
  `UpdateResponse` and `GetResponse` types and could therefore cause problems
  when `Update` and `Get` were used with `ask`. This was also a problem for
  Akka Typed.
* Introduce new messages types UpdateDataDeleted and GetDataDeleted
* Introduce SubscribeResponse because the responses can be both `Changed`
  and `Deleted` are responses to subscriptions. Important for Typed.
2019-09-10 17:09:04 +02:00
Patrik Nordwall
35232cce04 remove todo in Behavior.start (#27674) 2019-09-10 15:36:12 +02:00
Jakob Merljak
4576835cce Akka Stream log operator documentation fix (#27654)
* Fix Akka Stream log operator documentation example

* Keep Scala documentation example in sync
2019-09-10 13:24:24 +02:00
Patrik Nordwall
a32a89b656
Merge pull request #27658 from dsebban/fix-typo
Fix typo in CoupledTerminationFlow docs
2019-09-10 13:22:33 +02:00
Patrik Nordwall
77af1f773b
Merge pull request #27669 from taeguk/improve-mailboxes-doc
Improve tiny readability in mailboxes doc
2019-09-10 13:20:32 +02:00
Nicolas Vollmar
751918e84c Deprecates status message based api #27503 (#27519)
* Deprecates status message based api #27503
* Deprecates actorRefWithAck for actorRefWithBackpressure
2019-09-10 11:59:19 +02:00
Arnout Engelen
93bdd8ec09
Update to paradox 0.6.5 2019-09-10 11:20:12 +02:00
Patrik Nordwall
cf4c954009 Avoid publication of duplicate UnreachableDataCenter, #24955
* see scenario in added test, extracted from debug logs "New gossip published"
  from MultiDcSplitBrainSpec
* it publised UnreachableDataCenter even though it had already published that,
  when a new cross link is added as unreachable in the reachability table
* don't know why the implementation of diffUnreachableDataCenter/isReachable was
  so complicated, but no tests are failing for the changed implementation
2019-09-10 10:29:13 +02:00
Helena Edelson
aee0152da2 Failed: MultiDcClusterSharding #27663 (#27666) 2019-09-10 09:22:53 +02:00
Taeguk Kwon
c100ab90c2 Improve tiny readability in mailboxes doc 2019-09-10 16:12:08 +09:00
Helena Edelson
36f2731846
Multi-jvm assembly: deduplicate: META-INF default file #27667 (#27668) 2019-09-09 12:36:05 -07:00
Christopher Batey
9a4674f42f don't allow wrong system in ActorRefResolver, #27373 (#27391) 2019-09-09 16:42:18 +02:00
tanaka takaya
9aa0e593b0 Bump up dependencies. (#27586)
* Bump up dependencies.

* revert sslConfigVersion and sigarLoader.

* only used in tests.

* Bump up dependencies.
2019-09-09 14:54:09 +02:00
Helena Edelson
9a9e21a62b Consolidate Paradox settings, add includes workaround #27656 (#27657) 2019-09-09 14:25:33 +02:00
Patrik Nordwall
58e40e9193 Fix ByteStringSpec for Scala 2.13.1 (#27655) 2019-09-09 09:08:29 +02:00
dsebban
d297ce6906 Fix typo in CoupledTerminationFlow docs 2019-09-08 10:21:05 +03:00
Patrik Nordwall
f14acf7de8
Merge pull request #27653 from akka/wip-27652-assembly-patriknw
assemblyMergeStrategy first for logback-test.xml, #27652
2019-09-06 17:51:30 +02:00
Patrik Nordwall
cf813048dc assemblyMergeStrategy first for logback-test.xml 2019-09-06 14:59:57 +02:00
Patrik Nordwall
0783855b2c
Merge pull request #27552 from akka/wip-26537-slf4j-patriknw
Typed logging with slf4j, #26537
2019-09-06 11:33:56 +02:00
Johan Andrén
5f315100f6 Remove left over mention of using materializer for settings (#27646)
* Remove left over mention of using materializer for settings

* Not a list anymore
2019-09-06 10:19:21 +02:00
Patrik Nordwall
249c2e922d
Merge pull request #27645 from johanandren/wip-27640-watch-termination-sample-downstream-cancel
watchTermination now fails the future on downstream failure
2019-09-06 10:18:16 +02:00
Patrik Nordwall
2bd8c23240
Merge pull request #27643 from johanandren/wip-27639-stream-ref-cancellation-behavior
StreamRefs cancellation behavior
2019-09-06 10:17:43 +02:00
Patrik Nordwall
b5f6f4aa00
Merge pull request #27644 from akka/wip-27642-Materializer.create-patriknw
rename the new Materializer.create to createMaterializer, #27642
2019-09-06 10:15:00 +02:00
Patrik Nordwall
68424b4f55 Complete logging with SLF4J in Typed, #26537
* TestAppender interaction with LoggingEventFilter
  * TestAppender plays the same role as classic TestEventList
* replace Sl4jLoggingEvent.java
  * include MDC in testkit.LoggingEvent to allow for custom filter
    testing MDC
* fix tests
* fix log events in BehaviorSetKit, using SubstituteLogger
* MDC in EventSourcedBehavior
  * using raw MDC to set the persistenceId and persistencePhase fields
  * avoid access to MDC ThreadLocal if log isn't used

* Automatically enable eventStream Slf4jLogger for Typed (PR #27583)
  * amend the ActorSystem config on startup when config akka.use-slf4j=on
    and akka-slf4j in classpath
  * akka.use-slf4j is defined in akka-actor-typed reference.conf
  * also enable the Slf4jLoggingFilter automatically
  * remove config in tests

* Include actor path as akkaSource in MDC (PR #27587)
  * move logger init to ActorContextImpl since not specific to untyped (ActorContextAdapter)
  * careful to not access MDC ThreadLocal if logging isn't used (per message)
  * MDC is cleared (if used) from aroundReceive in ActorAdapter after processing each message
  * also changed MDC for EventSourcedBehavior to rely on context.log and the outer MDC.clear()
  * just removing the MDC values is not enough because the empty Map remains in the ThreadLocal

* Optimization of MDC interceptor (PR #27610)

* Extension methods to Logger as workaround for overload and varargs problem (PR #27605)
  * "ambiguous reference to overloaded definition" for 2 arg method
  * varargs not supported for primitive types
  * providing extension methods info2 and infoN (and friends) via implicit class LoggerOps
    as more convenient workaround for these problems

* New API for Typed LoggingEventFilter (PR #27611)
  * builder style
  * will make it easier to add more conditions
  * all conditions are AND:ed together which makes it easier to define custom filters
  * simplifies the implementation as a bonus
  * javadsl
  * use new api in all tests
  * leeway setting
  * verify that occurrences = 0 works
  * use javadsl in two tests
  * change interceptLogger, and some other feedback

* Testing utility to silence logging until failure (PR #27588)
  * Logback appender that captures all log events and can flush them
    later to other appenders
  * LogCapturing mixin for ScalaTest that flush the captured logging events
    when a test fails. Also clears the captured events after all tests.
  * Configuration in logback-test.xml
  * log capturing for JUnit tests too, using TestRule
  * Silence initial setup logging from Logback
  * make LogCapturing public
  * use LogCapturing in all tests
    * aside from multi-jvm, and a few extending AkkaSpec, so far
  * a few doc tests needed debug level

* mention in migration guide
* rename setLoggerClass to setLoggerName
* check for logback dependency to give nicer error message
* fix filterKeys, deprecated in 2.13
2019-09-06 10:09:54 +02:00
franciscolopezsancho
dd96d21ffa First step of changing to SL4J in Typed logging, #26537 2019-09-06 10:09:53 +02:00
Patrik Nordwall
1d38f1579a unmoored doc comment in PhasedFusingActorMaterializer (#27641) 2019-09-06 09:39:52 +02:00
Johan Andrén
f88ee384c3 watchTermination now fails the future on downstream failure #27640 2019-09-06 09:11:57 +02:00
Patrik Nordwall
e80b591115 rename the new Materializer.create to createMaterializer, #27642
* because static methods are resolved by looking at extended class too,
  and that results in ambigious method clash with existing create in
  ActorMaterializer
2019-09-06 09:02:22 +02:00
Johan Andrén
66280846c1 StreamRefs cancellation behavior #27639
* Updated multi-jvm test
* Updated migration guide
2019-09-06 08:55:51 +02:00
Johan Andrén
ed955e0da4 Propagate downstream cancellation failures (#27547)
* Add doc clarification about IOResult on sources
* Better error message for IOOperationIncompleteException

Co-Authored-By: Johannes Rudolph <johannes.rudolph@gmail.com>
2019-09-05 20:55:48 +02:00
Patrik Nordwall
4020036eb6
Merge pull request #27637 from akka/wip-enum-patriknw
fix deprecation warning for protobuf enum
2019-09-05 20:52:00 +02:00
Patrik Nordwall
4edbcde280 fix deprecation warning for protobuf enum 2019-09-05 19:32:15 +02:00
Johan Andrén
b68d67008a
Deprecate actor materializer (#27538) 2019-09-05 16:08:37 +02:00
Patrik Nordwall
8765a4fbe6
Merge pull request #27624 from akka/wip-24717-doc-apply-style12-patriknw
doc: stylish fault-tolerance.md, #24717
2019-09-05 14:46:30 +02:00