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

27758 commits

This branch
This branch
All branches
Author SHA1 Message Date
He-Pin(kerr)
57676cdc59
chore: Remove two deprecated methods in AbstractScheduler (#2052) 
* chore: Remove two deprecated methods in AbstractScheduler

* add newline at end of scheduler.excludes

---------

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
 2025-08-23 16:43:26 +08:00
PJ Fanning
40dfb57c90
Scheduler: remove more deprecated methods (#2037) 
* try to remove remaining deprecations in scheduler

* Update Scheduler.scala

* Update Cluster.scala

* mima
 2025-08-22 16:24:15 +01:00
scala-steward-asf[bot]
63637f472c
Update docker-java-core, ... to 3.6.0 (#2045) 
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
 2025-08-22 08:14:33 +01:00
dependabot[bot]
3408633b02
chore(deps): bump actions/setup-java from 4 to 5 (#2044) 
Bumps [actions/setup-java](https://github.com/actions/setup-java) from 4 to 5.
- [Release notes](https://github.com/actions/setup-java/releases)
- [Commits](https://github.com/actions/setup-java/compare/v4...v5)

---
updated-dependencies:
- dependency-name: actions/setup-java
  dependency-version: '5'
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2025-08-22 08:12:19 +01:00
Mikhail Sokolov
5d139e8b7c
Add AsyncWriteJournal option for disabling Resequencer (#2026) (#2027) 
* Add AsyncWriteJournal option for disabling Resequencer (#2026)

* Add @InternalApi as requested in review

* Update AsyncWriteJournal.scala

---------

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
 2025-08-21 08:32:00 +01:00
PJ Fanning
e0619c34fb
generate source with protobuf 32 (#2036) 
* generate source with protobuf 32

* javafmt
 2025-08-20 08:21:18 +01:00
Matthew de Detrich
adc1d669ce feat: Add materializeIntoSource 2025-08-18 14:09:43 +02:00
scala-steward-asf[bot]
28783fad61
Update sbt-develocity to 1.3.1 (#2034) 
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
 2025-08-17 02:13:10 +01:00
scala-steward-asf[bot]
098ba99905
Update netty-handler, netty-transport to 4.2.4.Final (#2035) 
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
 2025-08-17 02:12:44 +01:00
scala-steward-asf[bot]
8eaa673721
Update protobuf-java to 4.32.0 (#2033) 
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
 2025-08-17 02:10:07 +01:00
Ilya Kachalsky
97b3554871
Add JournalPersistFailed and JournalPersistRejected signals (#1961) 
* Add `JournalPersistFailed` and `JournalPersistRejected` signals with debug logging when emitted

* Add tests for `JournalPersistFailed` and `JournalPersistRejected` signals

* fix comments, remove pekko version

* applyCodeStyle

* change license
 2025-08-14 19:04:49 +01:00
PJ Fanning
53789a4296
remove Java8Cleaner (#2031) 2025-08-13 21:23:19 +01:00
PJ Fanning
96a84ca89b
use better byte buffer cleaner (#2020) 
* use better byte buffer cleaner

* scalafmt

* Update ByteBufferCleaner.java

* Update actor/src/main/java/org/apache/pekko/io/ByteBufferCleaner.java

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update DirectByteBufferPool.scala

* method handle

* Create ByteBufferCleanerSpec.scala

* invokeExact

* Update ByteBufferCleaner.java

* test buffer cleaner at init time

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
 2025-08-13 20:04:00 +01:00
dependabot[bot]
e7e71a3adf
chore(deps): bump sbt/setup-sbt from 1.1.11 to 1.1.12 (#2028) 
Bumps [sbt/setup-sbt](https://github.com/sbt/setup-sbt) from 1.1.11 to 1.1.12.
- [Release notes](https://github.com/sbt/setup-sbt/releases)
- [Commits](234370af13...f20dc1bc1f)

---
updated-dependencies:
- dependency-name: sbt/setup-sbt
  dependency-version: 1.1.12
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2025-08-13 13:52:13 +08:00
dependabot[bot]
3f71d29157
chore(deps): bump actions/checkout from 4 to 5 (#2025) 
Bumps [actions/checkout](https://github.com/actions/checkout) from 4 to 5.
- [Release notes](https://github.com/actions/checkout/releases)
- [Changelog](https://github.com/actions/checkout/blob/main/CHANGELOG.md)
- [Commits](https://github.com/actions/checkout/compare/v4...v5)

---
updated-dependencies:
- dependency-name: actions/checkout
  dependency-version: '5'
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2025-08-12 11:01:51 +01:00
PJ Fanning
08d3896310
remove old deprecated dns code (#2023) 
* remove old deprecated dns code

* remove test that uses old deprecated and now removed code

* Update DnsCompileOnlyDocSpec.scala

* Update remove-deprecated-methods.excludes

* mima

* try to fix docs

* more issues
 2025-08-10 08:52:41 +01:00
scala-steward-asf[bot]
fd1d7bb5af
Update aeron-client, aeron-driver to 1.48.6 (#2024) 
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
 2025-08-10 13:30:43 +08:00
PJ Fanning
957355cc3f
remove deprecated backoff classes and cluster-sharding settings (#2018) 
* remove deprecated backoff classes

* remove unused deprecated methods from ClusterShardingSettings

* Update remove-deprecated-methods.excludes

* Update ClusterShardingSettings.scala

* Update remove-deprecated-methods.excludes

* Update remove-deprecated-methods.excludes

* mima
 2025-08-08 09:02:29 +01:00
PJ Fanning
7af97edd86
remove deprecated stream operators (#2017) 
* remove deprecated stream operators

* more deprecations
 2025-08-08 09:02:08 +01:00
PJ Fanning
fc7ab2b8b5
remove unused code in actormaterializer (#2016) 
* remove unused code in actormaterializer

* Update remove-deprecated-methods.excludes
 2025-08-08 09:01:38 +01:00
PJ Fanning
5bfbfc5c89
with Java 17 min - we can call Thread.onSpinWait directly (#2021) 2025-08-08 08:57:52 +01:00
PJ Fanning
c11434abb4
remove final use of sun.misc.Unsafe (#1995) 
* remove final use of sun.misc.Unsafe

* Update PekkoBuild.scala

* update exception handling

* Update Unsafe.java
 2025-08-07 09:36:46 +01:00
PJ Fanning
4be8edcae4
try to remove some deprecated materializer methods (#2011) 
* try to remove some deprecated materializer methods

* more changes

* mima

* Update StreamRefSettings.scala

* make deprecated code that can't be deleted package private

* Update StreamRefSettings.scala

* Update ActorMaterializer.scala
 2025-08-07 09:36:01 +01:00
PJ Fanning
ad1ddf04c9
remove deprecated stream future operators (#2012) 
* remove deprecated stream future operators

* Update maybe.md
 2025-08-07 09:35:25 +01:00
PJ Fanning
7d5e5daa70
use CompletableFuture#failedStage (#2013) 2025-08-06 10:44:43 +08:00
PJ Fanning
1b8de23911
remove deprecated stream converters (#2006) 
* remove deprecated stream converters

* Update StreamConverters.scala

* Update remove-deprecated-methods.excludes

* Update DslFactoriesConsistencySpec.scala
 2025-08-05 15:21:35 +01:00
He-Pin(kerr)
836ae6025e
chore: Remove Java api Option (#2007) 2025-08-05 20:34:45 +08:00
He-Pin(kerr)
08ea94bb4b
chore: Migrate to pekko.japi.function (#2001) 
* chore: Remove javaapi.Function

* chore: Remove javaapi.Function2

* chore: Remove javaapi.Procedure

* chore: Remove javaapi.Predicate

* chore: Remove javaapi.Creator

* chore: Remove javaapi.Effect

* chore: Add mima

* Update actor-typed/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update stream/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update persistence/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update actor/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

---------

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
 2025-08-05 10:45:25 +08:00
scala-steward-asf[bot]
4228496e8f
Update sbt, scripted-plugin to 1.11.4 (#2005) 
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
 2025-08-04 12:36:38 +01:00
PJ Fanning
2ff7868281
don't test SessionRenegotiationFirstOne on java 24 (#2003) 2025-08-04 10:05:38 +01:00
PJ Fanning
1762931994
remove more deprecations (#1997) 
* remove more deprecations

* Update EventEnvelope.scala

* mima
 2025-08-03 11:02:59 +01:00
PJ Fanning
0dd219fab4
remove more deprecated pekko-stream methods (#1996) 
* remove deprecated setup methods

* remove deprecated lazyInit methods

* more deprecated methods

* Update SubFlow.scala

* scalafmt

* Update SubFlow.scala

* subflow/subsource

* Update DslFactoriesConsistencySpec.scala

* remove docs for removed operators
 2025-08-03 10:55:37 +01:00
PJ Fanning
c8960e2783
fix build issue related to URL deprecation (#1999) 2025-08-03 10:55:16 +01:00
He-Pin(kerr)
7325c729ce
Make use of eq and ne. (#1994) 
* chore: make use of eq instead of ==

* chore: make use of ne instead of !=
 2025-08-03 17:32:32 +08:00
PJ Fanning
19788583ee
remove more deprecated code (#1984) 
* remove more deprecated code

* Update DslFactoriesConsistencySpec.scala

* mima

* remove docs for removed FileIO operations

* more

* remove foreachparallel

* remove deprecated patterns

* tidy up

* Update remove-deprecated-methods.excludes
 2025-08-02 13:18:20 +01:00
PJ Fanning
db60119b42
avoid sun.misc.Unsafe by using VarHandles (#1990) 
* don't use unsafe to update nextName

Update Children.scala

Update Children.scala

use varhandle

Update AbstractActorCell.java

review comment

Update Children.scala

remove more usages of Unsafe

more

more

more

javafmt

Update LightArrayRevolverScheduler.scala

Update AbstractNodeQueue.java

Update AbstractBoundedNodeQueue.java

Revert "more"

This reverts commit ef119f4ebf9fa528a880dd13dd833e4e8c6effc8.

revert some promise actor changes

javafmt

* watchedBy

* Reapply "more"

This reverts commit ba2b43cd7d920a67e2e3ac9355c50c6b8169d451.

try again

* remove imports

* javafmt

* Update Unsafe.java

* Create util-unsafe-refactor.excludes

* internal api
 2025-08-02 12:10:52 +01:00
He-Pin(kerr)
e0f6a88435
=str Switch the type parameter order of UnfoldResourceSource. (#615) 2025-08-02 17:30:06 +08:00
PJ Fanning
b0bf1923a7
remove Unsafe.isIsJavaVersion9Plus (#1993) 
* remove Unsafe.isIsJavaVersion9Plus

* Update Unsafe.java

* Update Unsafe.java
 2025-08-02 09:26:53 +01:00
Matthew de Detrich
8ba5e48a1e Add back Scala 3 inline 2025-08-02 09:55:13 +02:00
He-Pin(kerr)
7bf6cf4969
=str Switch the type parameter order of UnfoldResourceSourceAsync (#616) 2025-08-02 14:48:35 +08:00
PJ Fanning
4bcfc9c7e2
Remove use of sun.misc.Unsafe in Mailbox (#1894) 
* remove use of Unsafe in Mailbox

* scalafmt

* use varhandles

* remove cast

* Update Mailbox.scala
 2025-08-01 09:24:05 +01:00
PJ Fanning
814962569e
don't use unsafe to update nextName (#1892) 
* don't use unsafe to update nextName

* Update Children.scala

* Update Children.scala

* use varhandle

* Update AbstractActorCell.java

* review comment

* Update Children.scala
 2025-08-01 08:53:45 +01:00
PJ Fanning
5aad47eb6c
remove deprecated code from pekko-remote (#1983) 
* remove deprecated code from pekko-remote

* undo disassociate changes

* Update Transport.scala

* Update remove-deprecated-methods.excludes

* Update remove-deprecated-methods.excludes
 2025-08-01 08:53:11 +01:00
PJ Fanning
666796ca7a
create jobs to publish 1.2 snapshots (#1987) 2025-07-31 20:05:03 +01:00
PJ Fanning
9e540b1236
remove deprecated names annotations (#1985) 2025-07-31 20:03:35 +01:00
PJ Fanning
c54e0ef89c
remove deprecated code from testkit (#1981) 
* remove deprecated code from testkit

compile issues

* Update StreamTestKit.scala

* mima

* Update remove-deprecated-methods.excludes
 2025-07-31 13:42:38 +02:00
PJ Fanning
1c1ca52ae4
move mima files back to 1.1.x (#1982) 2025-07-31 11:29:22 +01:00
PJ Fanning
6a995664ea
move jdk9 source code (#1976) 
* move jdk9 source code

* Update Events.scala

* javafmt

* unused import

* remote classes

* Update JFRRemotingFlightRecorder.scala

* stream tests

* javafmt

* doc links

* remove PekkoDependWalker

* build issues

* remove mention of JDK 9

* Update JavaFlowSupport.java
 2025-07-31 10:36:49 +01:00
PJ Fanning
2b5b3f8f43
remove some more deprecated code from pekko-actor (#1969) 
* remove some deprecated code from pekko-actor

Update Scheduler.scala

Update AbstractActor.scala

mima filters

remove more deprecated code from pekko-actor

revert

* Delete TypedActorRemoteDeploySpec.scala

* Update remove-deprecated-methods.excludes
 2025-07-31 09:07:14 +01:00
PJ Fanning
63b671c898
remove some deprecated cluster code (#1959) 
* remove some deprecated cluster code

* build issues

* Update Member.scala

* mima checks
 2025-07-31 08:31:11 +01:00