This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new 346d681 pekko 1.3 (#379)
346d681 is described below
commit 346d6812bab89c7d46a552e89a948925feed29ab
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Nov 24 12:01:30 2025 +0100
pekko 1.3 (#379)
* pekko 1.3
* Update QueryTestSpec.scala
---
.../query/JournalDaoStreamMessagesMemoryTest.scala | 2 +-
.../persistence/jdbc/query/QueryTestSpec.scala | 24 +++++++++++-----------
project/PekkoCoreDependency.scala | 2 +-
3 files changed, 14 insertions(+), 14 deletions(-)
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala
b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala
index 216d7b8..b6e3627 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala
@@ -114,7 +114,7 @@ abstract class
JournalDaoStreamMessagesMemoryTest(configFile: String)
case Failure(exception) =>
log.error("Failure when reading messages.", exception)
}
- .runWith(TestSink.probe)
+ .runWith(TestSink())
probe.request(10)
probe.within(20.seconds) {
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/QueryTestSpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/QueryTestSpec.scala
index 6be55a7..434483e 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/QueryTestSpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/QueryTestSpec.scala
@@ -71,12 +71,12 @@ class ScalaJdbcReadJournalOperations(readJournal:
JdbcReadJournal)(implicit syst
import system.dispatcher
def withCurrentPersistenceIds(within: FiniteDuration)(f:
TestSubscriber.Probe[String] => Unit): Unit = {
- val tp =
readJournal.currentPersistenceIds().runWith(TestSink.probe[String])
+ val tp = readJournal.currentPersistenceIds().runWith(TestSink[String]())
tp.within(within)(f(tp))
}
def withPersistenceIds(within: FiniteDuration)(f:
TestSubscriber.Probe[String] => Unit): Unit = {
- val tp = readJournal.persistenceIds().runWith(TestSink.probe[String])
+ val tp = readJournal.persistenceIds().runWith(TestSink[String]())
tp.within(within)(f(tp))
}
@@ -85,7 +85,7 @@ class ScalaJdbcReadJournalOperations(readJournal:
JdbcReadJournal)(implicit syst
f: TestSubscriber.Probe[EventEnvelope] => Unit): Unit = {
val tp = readJournal
.currentEventsByPersistenceId(persistenceId, fromSequenceNr,
toSequenceNr)
- .runWith(TestSink.probe[EventEnvelope])
+ .runWith(TestSink[EventEnvelope]())
tp.within(within)(f(tp))
}
@@ -94,19 +94,19 @@ class ScalaJdbcReadJournalOperations(readJournal:
JdbcReadJournal)(implicit syst
f: TestSubscriber.Probe[EventEnvelope] => Unit): Unit = {
val tp = readJournal
.eventsByPersistenceId(persistenceId, fromSequenceNr, toSequenceNr)
- .runWith(TestSink.probe[EventEnvelope])
+ .runWith(TestSink[EventEnvelope]())
tp.within(within)(f(tp))
}
def withCurrentEventsByTag(within: FiniteDuration)(tag: String, offset:
Offset)(
f: TestSubscriber.Probe[EventEnvelope] => Unit): Unit = {
- val tp = readJournal.currentEventsByTag(tag,
offset).runWith(TestSink.probe[EventEnvelope])
+ val tp = readJournal.currentEventsByTag(tag,
offset).runWith(TestSink[EventEnvelope]())
tp.within(within)(f(tp))
}
def withEventsByTag(within: FiniteDuration)(tag: String, offset: Offset)(
f: TestSubscriber.Probe[EventEnvelope] => Unit): Unit = {
- val tp = readJournal.eventsByTag(tag,
offset).runWith(TestSink.probe[EventEnvelope])
+ val tp = readJournal.eventsByTag(tag,
offset).runWith(TestSink[EventEnvelope]())
tp.within(within)(f(tp))
}
@@ -137,13 +137,13 @@ class JavaDslJdbcReadJournalOperations(readJournal:
javadsl.JdbcReadJournal)(
import system.dispatcher
def withCurrentPersistenceIds(within: FiniteDuration)(f:
TestSubscriber.Probe[String] => Unit): Unit = {
- val sink: pekko.stream.javadsl.Sink[String, TestSubscriber.Probe[String]]
= JavaSink.probe(system)
+ val sink: pekko.stream.javadsl.Sink[String, TestSubscriber.Probe[String]]
= JavaSink.create(system)
val tp = readJournal.currentPersistenceIds().runWith(sink, mat)
tp.within(within)(f(tp))
}
def withPersistenceIds(within: FiniteDuration)(f:
TestSubscriber.Probe[String] => Unit): Unit = {
- val sink: pekko.stream.javadsl.Sink[String, TestSubscriber.Probe[String]]
= JavaSink.probe(system)
+ val sink: pekko.stream.javadsl.Sink[String, TestSubscriber.Probe[String]]
= JavaSink.create(system)
val tp = readJournal.persistenceIds().runWith(sink, mat)
tp.within(within)(f(tp))
}
@@ -152,7 +152,7 @@ class JavaDslJdbcReadJournalOperations(readJournal:
javadsl.JdbcReadJournal)(
within: FiniteDuration)(persistenceId: String, fromSequenceNr: Long = 0,
toSequenceNr: Long = Long.MaxValue)(
f: TestSubscriber.Probe[EventEnvelope] => Unit): Unit = {
val sink: pekko.stream.javadsl.Sink[EventEnvelope,
TestSubscriber.Probe[EventEnvelope]] =
- JavaSink.probe(system)
+ JavaSink.create(system)
val tp = readJournal.currentEventsByPersistenceId(persistenceId,
fromSequenceNr, toSequenceNr).runWith(sink, mat)
tp.within(within)(f(tp))
}
@@ -161,7 +161,7 @@ class JavaDslJdbcReadJournalOperations(readJournal:
javadsl.JdbcReadJournal)(
within: FiniteDuration)(persistenceId: String, fromSequenceNr: Long,
toSequenceNr: Long)(
f: TestSubscriber.Probe[EventEnvelope] => Unit): Unit = {
val sink: pekko.stream.javadsl.Sink[EventEnvelope,
TestSubscriber.Probe[EventEnvelope]] =
- JavaSink.probe(system)
+ JavaSink.create(system)
val tp = readJournal.eventsByPersistenceId(persistenceId, fromSequenceNr,
toSequenceNr).runWith(sink, mat)
tp.within(within)(f(tp))
}
@@ -169,7 +169,7 @@ class JavaDslJdbcReadJournalOperations(readJournal:
javadsl.JdbcReadJournal)(
def withCurrentEventsByTag(within: FiniteDuration)(tag: String, offset:
Offset)(
f: TestSubscriber.Probe[EventEnvelope] => Unit): Unit = {
val sink: pekko.stream.javadsl.Sink[EventEnvelope,
TestSubscriber.Probe[EventEnvelope]] =
- JavaSink.probe(system)
+ JavaSink.create(system)
val tp = readJournal.currentEventsByTag(tag, offset).runWith(sink, mat)
tp.within(within)(f(tp))
}
@@ -177,7 +177,7 @@ class JavaDslJdbcReadJournalOperations(readJournal:
javadsl.JdbcReadJournal)(
def withEventsByTag(within: FiniteDuration)(tag: String, offset: Offset)(
f: TestSubscriber.Probe[EventEnvelope] => Unit): Unit = {
val sink: pekko.stream.javadsl.Sink[EventEnvelope,
TestSubscriber.Probe[EventEnvelope]] =
- JavaSink.probe(system)
+ JavaSink.create(system)
val tp = readJournal.eventsByTag(tag, offset).runWith(sink, mat)
tp.within(within)(f(tp))
}
diff --git a/project/PekkoCoreDependency.scala
b/project/PekkoCoreDependency.scala
index 1ad1bac..61d5bd7 100644
--- a/project/PekkoCoreDependency.scala
+++ b/project/PekkoCoreDependency.scala
@@ -20,5 +20,5 @@ import com.github.pjfanning.pekkobuild.PekkoDependency
object PekkoCoreDependency extends PekkoDependency {
override val checkProject: String = "pekko-cluster-sharding-typed"
override val module: Option[String] = None
- override val currentVersion: String = "1.2.1"
+ override val currentVersion: String = "1.3.0"
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
