Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ package org.apache.pekko.actor.typed.delivery.internal

import java.util.concurrent.TimeoutException

import scala.annotation.nowarn
import scala.collection.immutable
import scala.reflect.ClassTag
import scala.util.Failure
Expand Down Expand Up @@ -119,6 +120,7 @@ object ProducerControllerImpl {

private case class LoadStateReply[A](state: DurableProducerQueue.State[A]) extends InternalCommand
private case class LoadStateFailed(attempt: Int) extends InternalCommand
@nowarn("msg=never used")
private case class StoreMessageSentReply(ack: DurableProducerQueue.StoreMessageSentAck)
private case class StoreMessageSentFailed[A](messageSent: DurableProducerQueue.MessageSent[A], attempt: Int)
extends InternalCommand
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ import java.util.UUID
import java.util.concurrent.ThreadLocalRandom
import java.util.concurrent.TimeoutException

import scala.annotation.nowarn
import scala.reflect.ClassTag
import scala.util.Failure
import scala.util.Success
Expand Down Expand Up @@ -68,6 +69,7 @@ import pekko.util.Timeout

private case class LoadStateReply[A](state: DurableProducerQueue.State[A]) extends InternalCommand
private case class LoadStateFailed(attempt: Int) extends InternalCommand
@nowarn("msg=never used")
private case class StoreMessageSentReply(ack: DurableProducerQueue.StoreMessageSentAck)
Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

keeps for safety

private case class StoreMessageSentFailed[A](messageSent: DurableProducerQueue.MessageSent[A], attempt: Int)
extends InternalCommand
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ package org.apache.pekko.cluster.sharding.typed.delivery.internal

import java.util.concurrent.TimeoutException

import scala.annotation.nowarn
import scala.reflect.ClassTag
import scala.util.Failure
import scala.util.Success
Expand Down Expand Up @@ -69,6 +70,7 @@ import pekko.util.Timeout

private case class LoadStateReply[A](state: DurableProducerQueue.State[A]) extends InternalCommand
private case class LoadStateFailed(attempt: Int) extends InternalCommand
@nowarn("msg=never used")
private case class StoreMessageSentReply(ack: DurableProducerQueue.StoreMessageSentAck)
private case class StoreMessageSentFailed[A](messageSent: DurableProducerQueue.MessageSent[A], attempt: Int)
extends InternalCommand
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -121,6 +121,7 @@ private[pekko] object Shard {

private final case class EntityTerminated(ref: ActorRef)

@nowarn("msg=never used")
private final case class RememberedEntityIds(ids: Set[EntityId])
private final case class RememberEntityStoreCrashed(store: ActorRef)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,8 @@

package org.apache.pekko.coordination.lease.javadsl

import scala.annotation.nowarn

import org.apache.pekko
import pekko.actor.{ ActorSystem, ExtendedActorSystem, Extension, ExtensionId, ExtensionIdProvider }
import pekko.actor.ClassicActorSystemProvider
Expand All @@ -28,6 +30,7 @@ object LeaseProvider extends ExtensionId[LeaseProvider] with ExtensionIdProvider

override def createExtension(system: ExtendedActorSystem): LeaseProvider = new LeaseProvider(system)

@nowarn("msg=never used")
private final case class LeaseKey(leaseName: String, configPath: String, clientName: String)
}

Expand Down
2 changes: 1 addition & 1 deletion project/Dependencies.scala
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ object Dependencies {
val jacksonVersion2 = "2.20.1"
val jacksonVersion3 = "3.0.2"

val scala213Version = "2.13.17"
val scala213Version = "2.13.18"
val scala3Version = "3.3.7"
val allScalaVersions = Seq(scala213Version, scala3Version)

Expand Down