This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/pekko-persistence-cassandra.git
The following commit(s) were added to refs/heads/main by this push:
new ff7d069 Update pekkoVersion to 2.0.0-M4 (#487)
ff7d069 is described below
commit ff7d0696ea88d995b83d116b5a510881b5496438
Author: PJ Fanning <[email protected]>
AuthorDate: Sat Aug 22 14:31:58 2026 +0100
Update pekkoVersion to 2.0.0-M4 (#487)
* Update currentVersion to 2.0.0-M4
* test issues
---
.../apache/pekko/persistence/cassandra/journal/TagWriter.scala | 4 ++--
.../sharding/ClusterShardingQuickTerminationSpec.scala | 10 +++++-----
project/PekkoCoreDependency.scala | 2 +-
3 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriter.scala
b/core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriter.scala
index fa8016f..33a7ab3 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriter.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriter.scala
@@ -184,7 +184,7 @@ import scala.util.{ Failure, Success, Try }
become(idle(buffer.remove(pid), tagPidSequenceNrs + (pid ->
tagPidSequenceNr)))
sender() ! ResetPersistenceIdComplete
- case ReceiveTimeout =>
+ case _: ReceiveTimeout =>
if (buffer.isEmpty && tagPidSequenceNrs.isEmpty)
parent ! PassivateTagWriter(tag)
@@ -281,7 +281,7 @@ import scala.util.{ Failure, Success, Try }
become(writeInProgress(buffer.remove(pid), tagPidSequenceNrs + (pid ->
tp.pidTagSequenceNr), awaitingFlush))
sender() ! ResetPersistenceIdComplete
- case ReceiveTimeout =>
+ case _: ReceiveTimeout =>
// not idle
case StopTagWriter =>
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/cassandra/sharding/ClusterShardingQuickTerminationSpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/cassandra/sharding/ClusterShardingQuickTerminationSpec.scala
index a48bf6f..b934aee 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/cassandra/sharding/ClusterShardingQuickTerminationSpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/cassandra/sharding/ClusterShardingQuickTerminationSpec.scala
@@ -53,11 +53,11 @@ object ClusterShardingQuickTerminationSpec {
}
override def receiveCommand: Receive = {
- case Increment => persist(CounterChanged(+1))(updateState)
- case Decrement => persist(CounterChanged(-1))(updateState)
- case Get(_) => sender() ! count
- case ReceiveTimeout => context.parent ! Passivate(stopMessage = Stop)
- case Stop =>
+ case Increment => persist(CounterChanged(+1))(updateState)
+ case Decrement => persist(CounterChanged(-1))(updateState)
+ case Get(_) => sender() ! count
+ case _: ReceiveTimeout => context.parent ! Passivate(stopMessage = Stop)
+ case Stop =>
sender() ! Ack
context.stop(self)
}
diff --git a/project/PekkoCoreDependency.scala
b/project/PekkoCoreDependency.scala
index fc61931..b4a4169 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 = "2.0.0-M3"
+ override val currentVersion: String = "2.0.0-M4"
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
