From aaa8a2bb4c5cc60abdad5c84829e38a082701200 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Mon, 8 Feb 2016 18:20:34 +0100 Subject: [PATCH] silence deadletter logging of SubscribeAck * since it is normally (practially always) a local messages send that will not be rejected you don't care about the ack --- .../scala/akka/cluster/pubsub/DistributedPubSubMediator.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala b/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala index bbca5e2190..09447a2703 100644 --- a/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala +++ b/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala @@ -149,7 +149,7 @@ object DistributedPubSubMediator { object Unsubscribe { def apply(topic: String, ref: ActorRef) = new Unsubscribe(topic, ref) } - @SerialVersionUID(1L) final case class SubscribeAck(subscribe: Subscribe) + @SerialVersionUID(1L) final case class SubscribeAck(subscribe: Subscribe) extends DeadLetterSuppression @SerialVersionUID(1L) final case class UnsubscribeAck(unsubscribe: Unsubscribe) @SerialVersionUID(1L) final case class Publish(topic: String, msg: Any, sendOneMessageToEachGroup: Boolean) extends DistributedPubSubMessage { def this(topic: String, msg: Any) = this(topic, msg, sendOneMessageToEachGroup = false)