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

24541 commits

This branch
This branch
All branches
Author SHA1 Message Date
Patrik Nordwall
458d4ae546 add GPG_TTY instruction 2020-01-27 13:27:56 +01:00
Christopher Batey
a0268682de Add distributed workers to examples (#28506) 2020-01-22 13:57:07 +01:00
Patrik Nordwall
b30f8746d3
Merge pull request #28470 from akka/wip-28416-region-reg-patriknw 
Shard region registration to more potential oldest, #28416
 2020-01-22 08:40:01 +01:00
Arnout Engelen
ef08d9fe5c Don't warn about discarded return values (#28403) 
* Since we have and use many API's where the return value can be safely
ignored.
* akka-cluster-sharding also does implicit widening
 2020-01-21 20:47:18 -08:00
Patrik Nordwall
a9750b3c37
Merge pull request #28483 from helena/failure-joinconfig-checker-sharding 
Failed: JoinConfigCompatCheckerClusterShardingSpec #28477
 2020-01-21 20:04:24 +01:00
Christopher Batey
cbf9f71c32
External shard allocation strategy (#28211) 2020-01-21 16:08:51 +00:00
Patrik Nordwall
cbde44fc48
Merge pull request #28496 from akka/managingBlockingExample 
Update 'managing blocking' examples
 2020-01-21 12:54:15 +01:00
Yury Gribkov
004581a399 Rename RecoveryPermitter.pending for telemetry (#28503) 2020-01-21 09:15:30 +01:00
Patrik Nordwall
6072f6d263
Fix memory leak of restarting Artery outbound stream, #28390 (#28478) 
* Fix memory leak of restarting Artery outbound stream, #28390 (#28407)

* If the handshake doesn't complete the Promise in AssociationState was
  not completed and each new restarted stream added future callback to
  it OutboundHandshake stage. Those references are kept in the promise
  and therefore old OutboundHandshake (and probably entire stream) couldn't
  be garbage collected.
* Using own notification mechanism to have control of listener deregistration
  from postStop instead of using Promise/Future.
* Trying to create new Promise after failure/restart would be difficult due
  to that the same AssociationState Promise is accessed from several outbound
  streams, all possibly restarted individually. Therefore easier to cleanup
  from postStop.

(cherry picked from commit 3b7e6095df25d2551c122944f08f869255fb20ca)

* move mima filter to 2.6.1.backwards.excludes
 2020-01-20 15:33:44 +01:00
Eric Loots
a320475e86 Fix typo in Akka Typed Style guide (#28499) 2020-01-20 13:28:34 +01:00
Scala Steward
c7e03584a6 Update sbt to 1.3.7 (#28495) 2020-01-20 10:29:11 +01:00
Johan Andrén
fc0c98e17a
Support cancellation propagation in StreamRefs #28317 2020-01-20 10:28:26 +01:00
Helena Edelson
90d1f72f38 Failed: JoinConfigCompatCheckerClusterShardingSpec #28477 2020-01-17 11:16:37 -08:00
Patrik Nordwall
41ef4bb66e
Merge pull request #28473 from limansky/scalatest310 
Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
 2020-01-17 16:57:19 +01:00
Arnout Engelen
3dc20796ca Update 'managing blocking' examples 
Having only one blocking actor is not enough, since then only one dispatcher
thread will be blocked at a time.
 2020-01-17 15:35:05 +01:00
Mikhail Limansky
feb9499431 Update after merge 2020-01-17 16:56:15 +03:00
Mikhail Limansky
52c01832da Merge remote-tracking branch 'akka/master' into scalatest310 2020-01-17 16:03:32 +03:00
Mikhail Limansky
8b06168db6 Remove ScalaTestJUnit from provided dependencies. 2020-01-17 15:53:24 +03:00
Johan Andrén
098118251d Missing Java getters for optional fields on akka.actor.Address (#28493) 2020-01-15 17:45:38 -08:00
Arnout Engelen
9b9972a854
Remove deprecated actorRefWithAck from 'pending' lists (#28337) 
As we don't plan to document this one anymore, so it's already
ignored in the 'ignore' list
 2020-01-15 16:40:06 +01:00
Arnout Engelen
087ed4b5a5 Add source.completionStage example #25468 (#28338) 2020-01-15 15:04:15 +01:00
Christopher Batey
a8086e86e5 Operator doc for flatmap merge (#28488) 2020-01-15 13:20:41 +01:00
Mikhail Limansky
3fccda9f4c Update multi-jmv tests for ScalaTest 3.1.0 2020-01-15 12:31:07 +03:00
Johan Andrén
f891f17abd
Increase logger startup timeout in cluster metric tests #27955 2020-01-15 10:22:43 +01:00
Mikhail Limansky
3abce05e79 Add MiMa filter for ScalaTest 3.1.0 2020-01-14 19:53:27 +03:00
Johan Andrén
3ca7cb0f94
Examples for the sliding operator #25468 2020-01-14 16:03:11 +01:00
Johan Andrén
044e706eb9
Incorrect assumptions in LazyAndFutureSourcesTest (#28479) 2020-01-14 13:53:05 +01:00
Arnout Engelen
4c9c05cfde Check headers on travis (#28466) 
To check them on 2.13 early as well
 2020-01-14 13:41:46 +01:00
Patrik Nordwall
47d2b680c8
Merge pull request #28486 from akka/update/sbt-reproducible-builds 
Update sbt-reproducible-builds to 0.23
 2020-01-14 13:10:52 +01:00
Johannes Rudolph
ec208cad08
Merge branch 'master' into scalatest310 2020-01-14 12:03:32 +01:00
Scala Steward
a1d9487ecd Update aeron-client, aeron-driver to 1.25.0 (#28475) 
* Update aeron-client, aeron-driver to 1.25.0

* Update agrona to 1.2.0

Co-authored-by: Arnout Engelen <github@bzzt.net>
 2020-01-14 10:34:27 +00:00
Scala Steward
9480d6415c Update sbt-pgp to 2.0.1 (#28396) 2020-01-14 10:33:10 +00:00
Scala Steward
ee6d48c7ba Update jul-to-slf4j, log4j-over-slf4j, ... to 1.7.30 (#28398) 
* Update jul-to-slf4j, log4j-over-slf4j, ... to 1.7.30

* Update jul-to-slf4j, log4j-over-slf4j, ... to 1.7.30
 2020-01-14 10:32:37 +00:00
Scala Steward
b74809ed77 Update metrics-core, metrics-jvm to 4.1.2 (#28375) 2020-01-14 10:29:31 +00:00
Scala Steward
53516fcc32 Update scalacheck to 1.14.3 (#28378) 2020-01-14 10:28:55 +00:00
Patrik Nordwall
aae7604dce Logging of UnhandledMessage, #28260 (#28414) 
* Logging of UnhandledMessage, #28260

* make use of the existing logging of dead letter
  also for UnhandledMessage
* Akka Typed publishes UnhandledMessage in same way so those
  will also be logged

* fix test failure in EventStreamSpec

* feedback
 2020-01-14 10:26:44 +00:00
Arnout Engelen
78a357e0f5 Update sbt-reproducible-builds to 0.23 (#28485) 2020-01-14 11:22:20 +01:00
Arnout Engelen
44ad322a56 Deprecate EventEnvelope ctor without timestamp (#28454) 2020-01-14 10:22:07 +00:00
Patrik Nordwall
ab2300c4cb doc: example for splitWhen and splitAfter, #25468 (#28480) 
* doc: example for splitWhen and splitAfter, #25468
 2020-01-14 10:17:20 +00:00
Patrik Nordwall
169098070d doc: links to videos (#28481) 2020-01-14 10:59:48 +01:00
Helena Edelson
8157338346 Minor doc and scaladoc cleanup. (#28484) 2020-01-14 10:59:12 +01:00
Johan Andrén
b5d2bcdbb0 Fix problems with byte string copy to array 2.13 (#28468) 
* copyToArray unbroken on 2.13 #28465
* Skip discipline flags in console (driving me crazy!)
 2020-01-14 10:51:37 +01:00
Patrik Nordwall
856c4ff6f6
Rename Start message in HelloWorld (#28469) 
* Rename more Start to SayHello

* fix copyright year in InmemJournalSpec
 2020-01-13 14:48:31 +01:00
Mikhail Limansky
c23e3a53dd Fix compile error in multi-jvm test 2020-01-13 13:27:30 +03:00
Mikhail Limansky
3f6a92aecf Merge remote-tracking branch 'akka/master' into scalatest310 
# Conflicts:
#	akka-cluster-sharding-typed/src/test/java/jdocs/akka/cluster/sharding/typed/AccountExampleDocTest.java
 2020-01-13 13:22:54 +03:00
Jorge Cruz
e55a9fcf89 Add missing word Map to tutorial_4.md (#28472) 2020-01-13 10:56:42 +01:00
Mikhail Limansky
6723c6cc59 Fix test compilation issue in akka-cluster-typed 2020-01-13 12:40:06 +03:00
Patrik Nordwall
cdc45c128d
Publish operations from InmemJournal (#28332) 
* small feature that is useful for verifying that expected events were persisted
* doc example
* also enable serialization test config
 2020-01-13 09:46:43 +01:00
Mike Limansky
d9ed927df0 Update to ScalaTest 3.1.0, fix #28289. 2020-01-11 15:15:10 +03:00
Johan Andrén
4749b11be8 Typed receptionist deregistration (#28406) 
* Co-authored-by: tipame <33191778+tipame@users.noreply.github.com>
 2020-01-10 09:34:04 -08:00