diff --git a/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/DistributedMessages.cs b/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/DistributedMessages.cs index 4154cecc804..8d51a0a2911 100644 --- a/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/DistributedMessages.cs +++ b/src/contrib/cluster/Akka.Cluster.Tools/PublishSubscribe/DistributedMessages.cs @@ -441,9 +441,11 @@ public enum PublishFailReason MediatorShuttingDown } - public sealed record PublishFailed(PublishWithAck Message, PublishFailReason Reason): IDeadLetterSuppression; + public interface IPublishResponse; - public sealed record PublishSucceeded(PublishWithAck Message): IDeadLetterSuppression; + public sealed record PublishFailed(PublishWithAck Message, PublishFailReason Reason): IPublishResponse, IDeadLetterSuppression; + + public sealed record PublishSucceeded(PublishWithAck Message): IPublishResponse, IDeadLetterSuppression; /// /// TBD diff --git a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.DotNet.verified.txt b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.DotNet.verified.txt index 8c8ff8a9041..e87ea8710a2 100644 --- a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.DotNet.verified.txt +++ b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.DotNet.verified.txt @@ -281,6 +281,7 @@ namespace Akka.Cluster.Tools.PublishSubscribe public static Akka.Cluster.Tools.PublishSubscribe.GetTopics Instance { get; } } public interface IDistributedPubSubMessage { } + public interface IPublishResponse { } public sealed class Publish : Akka.Actor.IWrappedMessage, Akka.Cluster.Tools.PublishSubscribe.IDistributedPubSubMessage, System.IEquatable { public Publish(string topic, object message, bool sendOneMessageToEachGroup = False) { } @@ -297,13 +298,13 @@ namespace Akka.Cluster.Tools.PublishSubscribe Timeout = 0, MediatorShuttingDown = 1, } - public sealed class PublishFailed : Akka.Event.IDeadLetterSuppression, System.IEquatable + public sealed class PublishFailed : Akka.Cluster.Tools.PublishSubscribe.IPublishResponse, Akka.Event.IDeadLetterSuppression, System.IEquatable { public PublishFailed(Akka.Cluster.Tools.PublishSubscribe.PublishWithAck Message, Akka.Cluster.Tools.PublishSubscribe.PublishFailReason Reason) { } public Akka.Cluster.Tools.PublishSubscribe.PublishWithAck Message { get; set; } public Akka.Cluster.Tools.PublishSubscribe.PublishFailReason Reason { get; set; } } - public sealed class PublishSucceeded : Akka.Event.IDeadLetterSuppression, System.IEquatable + public sealed class PublishSucceeded : Akka.Cluster.Tools.PublishSubscribe.IPublishResponse, Akka.Event.IDeadLetterSuppression, System.IEquatable { public PublishSucceeded(Akka.Cluster.Tools.PublishSubscribe.PublishWithAck Message) { } public Akka.Cluster.Tools.PublishSubscribe.PublishWithAck Message { get; set; } diff --git a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.Net.verified.txt b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.Net.verified.txt index 744cb971ab7..d2660fe7688 100644 --- a/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.Net.verified.txt +++ b/src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveClusterTools.Net.verified.txt @@ -281,6 +281,7 @@ namespace Akka.Cluster.Tools.PublishSubscribe public static Akka.Cluster.Tools.PublishSubscribe.GetTopics Instance { get; } } public interface IDistributedPubSubMessage { } + public interface IPublishResponse { } public sealed class Publish : Akka.Actor.IWrappedMessage, Akka.Cluster.Tools.PublishSubscribe.IDistributedPubSubMessage, System.IEquatable { public Publish(string topic, object message, bool sendOneMessageToEachGroup = False) { } @@ -297,13 +298,13 @@ namespace Akka.Cluster.Tools.PublishSubscribe Timeout = 0, MediatorShuttingDown = 1, } - public sealed class PublishFailed : Akka.Event.IDeadLetterSuppression, System.IEquatable + public sealed class PublishFailed : Akka.Cluster.Tools.PublishSubscribe.IPublishResponse, Akka.Event.IDeadLetterSuppression, System.IEquatable { public PublishFailed(Akka.Cluster.Tools.PublishSubscribe.PublishWithAck Message, Akka.Cluster.Tools.PublishSubscribe.PublishFailReason Reason) { } public Akka.Cluster.Tools.PublishSubscribe.PublishWithAck Message { get; set; } public Akka.Cluster.Tools.PublishSubscribe.PublishFailReason Reason { get; set; } } - public sealed class PublishSucceeded : Akka.Event.IDeadLetterSuppression, System.IEquatable + public sealed class PublishSucceeded : Akka.Cluster.Tools.PublishSubscribe.IPublishResponse, Akka.Event.IDeadLetterSuppression, System.IEquatable { public PublishSucceeded(Akka.Cluster.Tools.PublishSubscribe.PublishWithAck Message) { } public Akka.Cluster.Tools.PublishSubscribe.PublishWithAck Message { get; set; }