raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=cls #17699 Add some DeadLetterSuppression

Browse source
This commit is contained in:
Patrik Nordwall 2015-08-18 16:32:18 +02:00
parent a0bee97f26
commit 775a2ca40c
4 changed files with 15 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsCollector.scala
View file

@ -15,6 +15,7 @@ import scala.collection.immutable
import akka.cluster.MemberStatus
import scala.concurrent.forkjoin.ThreadLocalRandom
import akka.actor.Terminated
import akka.actor.DeadLetterSuppression
/**
* Runtime collection management commands.
@ -109,6 +110,7 @@ private[metrics] trait ClusterMetricsMessage extends Serializable
*/
@SerialVersionUID(1L)
private[metrics] final case class MetricsGossipEnvelope(from: Address, gossip: MetricsGossip, reply: Boolean) extends ClusterMetricsMessage
with DeadLetterSuppression
/**
* INTERNAL API.

7
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala
View file

@ -26,6 +26,7 @@ import akka.persistence.SaveSnapshotFailure
import akka.persistence.SaveSnapshotSuccess
import akka.persistence.SnapshotOffer
import akka.pattern.pipe
import akka.actor.DeadLetterSuppression
/**
* @see [[ClusterSharding$ ClusterSharding extension]]
@ -168,10 +169,14 @@ object ShardCoordinator {
* `ShardRegion` registers to `ShardCoordinator`, until it receives [[RegisterAck]].
*/
@SerialVersionUID(1L) final case class Register(shardRegion: ActorRef) extends CoordinatorCommand
with DeadLetterSuppression
/**
* `ShardRegion` in proxy only mode registers to `ShardCoordinator`, until it receives [[RegisterAck]].
*/
@SerialVersionUID(1L) final case class RegisterProxy(shardRegionProxy: ActorRef) extends CoordinatorCommand
with DeadLetterSuppression
/**
* Acknowledgement from `ShardCoordinator` that [[Register]] or [[RegisterProxy]] was successful.
*/
@ -181,6 +186,8 @@ object ShardCoordinator {
* to the `ShardCoordinator`.
*/
@SerialVersionUID(1L) final case class GetShardHome(shard: ShardId) extends CoordinatorCommand
with DeadLetterSuppression
/**
* `ShardCoordinator` replies with this message for [[GetShardHome]] requests.
*/

3
akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala
View file

@ -41,6 +41,7 @@ import com.typesafe.config.Config
import akka.actor.NoSerializationVerificationNeeded
import akka.actor.Deploy
import akka.dispatch.Dispatchers
import akka.actor.DeadLetterSuppression
object DistributedPubSubSettings {
/**
@ -234,8 +235,10 @@ object DistributedPubSubMediator {
@SerialVersionUID(1L)
final case class Status(versions: Map[Address, Long]) extends DistributedPubSubMessage
with DeadLetterSuppression
@SerialVersionUID(1L)
final case class Delta(buckets: immutable.Iterable[Bucket]) extends DistributedPubSubMessage
with DeadLetterSuppression
case object GossipTick

5
akka-cluster-tools/src/main/scala/akka/cluster/singleton/ClusterSingletonManager.scala
View file

@ -15,6 +15,7 @@ import akka.actor.ActorSystem
import akka.actor.ActorRef
import akka.actor.ActorSelection
import akka.actor.Address
import akka.actor.DeadLetterSuppression
import akka.actor.FSM
import akka.actor.Props
import akka.actor.Terminated
@ -147,7 +148,7 @@ object ClusterSingletonManager {
* hand-over process. `HandOverInProgress` and `HandOverDone`
* are expected replies.
*/
case object HandOverToMe extends ClusterSingletonMessage
case object HandOverToMe extends ClusterSingletonMessage with DeadLetterSuppression
/**
* Confirmation by the previous oldest that the hand
* over process, shut down of the singleton actor, has
@ -167,7 +168,7 @@ object ClusterSingletonManager {
* oldest immediately, without knowing who was previous
* oldest.
*/
case object TakeOverFromMe extends ClusterSingletonMessage
case object TakeOverFromMe extends ClusterSingletonMessage with DeadLetterSuppression
final case class HandOverRetry(count: Int)
final case class TakeOverRetry(count: Int)