Skip to content

Commit

Permalink
Read stash capacity from actor's mailbox or dispatcher configuration (#…
Browse files Browse the repository at this point in the history 
…6323)
  • Loading branch information
@ismaelhamed
ismaelhamed authored Jan 3, 2023
1 parent 124a378 commit 4d124ce
Show file tree
Hide file tree
Showing 10 changed files with 465 additions and 130 deletions.
19 changes: 13 additions & 6 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.Core.verified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1933,13 +1933,13 @@ namespace Akka.Actor.Internal
{
public abstract class AbstractStash : Akka.Actor.IStash
{
protected AbstractStash(Akka.Actor.IActorContext context, int capacity = 100) { }
protected AbstractStash(Akka.Actor.IActorContext context) { }
public System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> ClearStash() { }
public void Prepend(System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> envelopes) { }
public void Stash() { }
public void Unstash() { }
public void UnstashAll() { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> predicate) { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> filterPredicate) { }
}
public class ActorSystemImpl : Akka.Actor.ExtendedActorSystem
{
Expand Down Expand Up @@ -1988,7 +1988,7 @@ namespace Akka.Actor.Internal
}
public class BoundedStashImpl : Akka.Actor.Internal.AbstractStash
{
public BoundedStashImpl(Akka.Actor.IActorContext context, int capacity = 100) { }
public BoundedStashImpl(Akka.Actor.IActorContext context) { }
}
public class ChildNameReserved : Akka.Actor.Internal.IChildStats
{
Expand Down Expand Up @@ -2486,14 +2486,14 @@ namespace Akka.Dispatch
public static void RunTask(System.Func<System.Threading.Tasks.Task> asyncAction) { }
protected override bool TryExecuteTaskInline(System.Threading.Tasks.Task task, bool taskWasPreviouslyQueued) { }
}
public sealed class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>
public class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedDequeBasedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
public System.TimeSpan PushTimeout { get; }
public override Akka.Dispatch.MessageQueues.IMessageQueue Create(Akka.Actor.IActorRef owner, Akka.Actor.ActorSystem system) { }
}
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
Expand Down Expand Up @@ -2549,6 +2549,8 @@ namespace Akka.Dispatch
public Akka.Configuration.Config DefaultDispatcherConfig { get; }
public Akka.Dispatch.MessageDispatcher DefaultGlobalDispatcher { get; }
public Akka.Dispatch.IDispatcherPrerequisites Prerequisites { get; }
[Akka.Annotations.InternalApiAttribute()]
public static Akka.Configuration.Config GetConfig(Akka.Configuration.Config config, string id, int depth = 0) { }
public bool HasDispatcher(string id) { }
public Akka.Dispatch.MessageDispatcher Lookup(string dispatcherName) { }
public bool RegisterConfigurator(string id, Akka.Dispatch.MessageDispatcherConfigurator configurator) { }
Expand Down Expand Up @@ -2602,6 +2604,10 @@ namespace Akka.Dispatch
public interface IMultipleConsumerSemantics : Akka.Dispatch.ISemantics { }
public interface IProducesMessageQueue<TQueue>
where TQueue : Akka.Dispatch.MessageQueues.IMessageQueue { }
public interface IProducesPushTimeoutSemanticsMailbox
{
System.TimeSpan PushTimeout { get; }
}
public interface IRequiresMessageQueue<T>
where T : Akka.Dispatch.ISemantics { }
public interface IRunnable
Expand Down Expand Up @@ -2635,13 +2641,14 @@ namespace Akka.Dispatch
public static readonly string NoMailboxRequirement;
public Mailboxes(Akka.Actor.ActorSystem system) { }
public Akka.Actor.DeadLetterMailbox DeadLetterMailbox { get; }
public System.Type FromConfig(string path) { }
public Akka.Dispatch.MailboxType GetMailboxType(Akka.Actor.Props props, Akka.Configuration.Config dispatcherConfig) { }
public System.Type GetRequiredType(System.Type actorType) { }
public bool HasRequiredType(System.Type actorType) { }
public Akka.Dispatch.MailboxType Lookup(string id) { }
public Akka.Dispatch.MailboxType LookupByQueueType(System.Type queueType) { }
public bool ProducesMessageQueue(System.Type mailboxType) { }
[Akka.Annotations.InternalApiAttribute()]
public int StashCapacity(string dispatcher, string mailbox) { }
}
public abstract class MessageDispatcher
{
Expand Down
19 changes: 13 additions & 6 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.DotNet.verified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1935,13 +1935,13 @@ namespace Akka.Actor.Internal
{
public abstract class AbstractStash : Akka.Actor.IStash
{
protected AbstractStash(Akka.Actor.IActorContext context, int capacity = 100) { }
protected AbstractStash(Akka.Actor.IActorContext context) { }
public System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> ClearStash() { }
public void Prepend(System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> envelopes) { }
public void Stash() { }
public void Unstash() { }
public void UnstashAll() { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> predicate) { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> filterPredicate) { }
}
public class ActorSystemImpl : Akka.Actor.ExtendedActorSystem
{
Expand Down Expand Up @@ -1990,7 +1990,7 @@ namespace Akka.Actor.Internal
}
public class BoundedStashImpl : Akka.Actor.Internal.AbstractStash
{
public BoundedStashImpl(Akka.Actor.IActorContext context, int capacity = 100) { }
public BoundedStashImpl(Akka.Actor.IActorContext context) { }
}
public class ChildNameReserved : Akka.Actor.Internal.IChildStats
{
Expand Down Expand Up @@ -2490,14 +2490,14 @@ namespace Akka.Dispatch
public static void RunTask(System.Func<System.Threading.Tasks.Task> asyncAction) { }
protected override bool TryExecuteTaskInline(System.Threading.Tasks.Task task, bool taskWasPreviouslyQueued) { }
}
public sealed class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>
public class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedDequeBasedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
public System.TimeSpan PushTimeout { get; }
public override Akka.Dispatch.MessageQueues.IMessageQueue Create(Akka.Actor.IActorRef owner, Akka.Actor.ActorSystem system) { }
}
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
Expand Down Expand Up @@ -2553,6 +2553,8 @@ namespace Akka.Dispatch
public Akka.Configuration.Config DefaultDispatcherConfig { get; }
public Akka.Dispatch.MessageDispatcher DefaultGlobalDispatcher { get; }
public Akka.Dispatch.IDispatcherPrerequisites Prerequisites { get; }
[Akka.Annotations.InternalApiAttribute()]
public static Akka.Configuration.Config GetConfig(Akka.Configuration.Config config, string id, int depth = 0) { }
public bool HasDispatcher(string id) { }
public Akka.Dispatch.MessageDispatcher Lookup(string dispatcherName) { }
public bool RegisterConfigurator(string id, Akka.Dispatch.MessageDispatcherConfigurator configurator) { }
Expand Down Expand Up @@ -2606,6 +2608,10 @@ namespace Akka.Dispatch
public interface IMultipleConsumerSemantics : Akka.Dispatch.ISemantics { }
public interface IProducesMessageQueue<TQueue>
where TQueue : Akka.Dispatch.MessageQueues.IMessageQueue { }
public interface IProducesPushTimeoutSemanticsMailbox
{
System.TimeSpan PushTimeout { get; }
}
public interface IRequiresMessageQueue<T>
where T : Akka.Dispatch.ISemantics { }
public interface IRunnable : System.Threading.IThreadPoolWorkItem
Expand Down Expand Up @@ -2640,13 +2646,14 @@ namespace Akka.Dispatch
public static readonly string NoMailboxRequirement;
public Mailboxes(Akka.Actor.ActorSystem system) { }
public Akka.Actor.DeadLetterMailbox DeadLetterMailbox { get; }
public System.Type FromConfig(string path) { }
public Akka.Dispatch.MailboxType GetMailboxType(Akka.Actor.Props props, Akka.Configuration.Config dispatcherConfig) { }
public System.Type GetRequiredType(System.Type actorType) { }
public bool HasRequiredType(System.Type actorType) { }
public Akka.Dispatch.MailboxType Lookup(string id) { }
public Akka.Dispatch.MailboxType LookupByQueueType(System.Type queueType) { }
public bool ProducesMessageQueue(System.Type mailboxType) { }
[Akka.Annotations.InternalApiAttribute()]
public int StashCapacity(string dispatcher, string mailbox) { }
}
public abstract class MessageDispatcher
{
Expand Down
19 changes: 13 additions & 6 deletions src/core/Akka.API.Tests/verify/CoreAPISpec.ApproveCore.Net.verified.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1933,13 +1933,13 @@ namespace Akka.Actor.Internal
{
public abstract class AbstractStash : Akka.Actor.IStash
{
protected AbstractStash(Akka.Actor.IActorContext context, int capacity = 100) { }
protected AbstractStash(Akka.Actor.IActorContext context) { }
public System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> ClearStash() { }
public void Prepend(System.Collections.Generic.IEnumerable<Akka.Actor.Envelope> envelopes) { }
public void Stash() { }
public void Unstash() { }
public void UnstashAll() { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> predicate) { }
public void UnstashAll(System.Func<Akka.Actor.Envelope, bool> filterPredicate) { }
}
public class ActorSystemImpl : Akka.Actor.ExtendedActorSystem
{
Expand Down Expand Up @@ -1988,7 +1988,7 @@ namespace Akka.Actor.Internal
}
public class BoundedStashImpl : Akka.Actor.Internal.AbstractStash
{
public BoundedStashImpl(Akka.Actor.IActorContext context, int capacity = 100) { }
public BoundedStashImpl(Akka.Actor.IActorContext context) { }
}
public class ChildNameReserved : Akka.Actor.Internal.IChildStats
{
Expand Down Expand Up @@ -2486,14 +2486,14 @@ namespace Akka.Dispatch
public static void RunTask(System.Func<System.Threading.Tasks.Task> asyncAction) { }
protected override bool TryExecuteTaskInline(System.Threading.Tasks.Task task, bool taskWasPreviouslyQueued) { }
}
public sealed class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>
public class BoundedDequeBasedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedDequeMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedDequeBasedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
public System.TimeSpan PushTimeout { get; }
public override Akka.Dispatch.MessageQueues.IMessageQueue Create(Akka.Actor.IActorRef owner, Akka.Actor.ActorSystem system) { }
}
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>
public sealed class BoundedMailbox : Akka.Dispatch.MailboxType, Akka.Dispatch.IProducesMessageQueue<Akka.Dispatch.MessageQueues.BoundedMessageQueue>, Akka.Dispatch.IProducesPushTimeoutSemanticsMailbox
{
public BoundedMailbox(Akka.Actor.Settings settings, Akka.Configuration.Config config) { }
public int Capacity { get; }
Expand Down Expand Up @@ -2549,6 +2549,8 @@ namespace Akka.Dispatch
public Akka.Configuration.Config DefaultDispatcherConfig { get; }
public Akka.Dispatch.MessageDispatcher DefaultGlobalDispatcher { get; }
public Akka.Dispatch.IDispatcherPrerequisites Prerequisites { get; }
[Akka.Annotations.InternalApiAttribute()]
public static Akka.Configuration.Config GetConfig(Akka.Configuration.Config config, string id, int depth = 0) { }
public bool HasDispatcher(string id) { }
public Akka.Dispatch.MessageDispatcher Lookup(string dispatcherName) { }
public bool RegisterConfigurator(string id, Akka.Dispatch.MessageDispatcherConfigurator configurator) { }
Expand Down Expand Up @@ -2602,6 +2604,10 @@ namespace Akka.Dispatch
public interface IMultipleConsumerSemantics : Akka.Dispatch.ISemantics { }
public interface IProducesMessageQueue<TQueue>
where TQueue : Akka.Dispatch.MessageQueues.IMessageQueue { }
public interface IProducesPushTimeoutSemanticsMailbox
{
System.TimeSpan PushTimeout { get; }
}
public interface IRequiresMessageQueue<T>
where T : Akka.Dispatch.ISemantics { }
public interface IRunnable
Expand Down Expand Up @@ -2635,13 +2641,14 @@ namespace Akka.Dispatch
public static readonly string NoMailboxRequirement;
public Mailboxes(Akka.Actor.ActorSystem system) { }
public Akka.Actor.DeadLetterMailbox DeadLetterMailbox { get; }
public System.Type FromConfig(string path) { }
public Akka.Dispatch.MailboxType GetMailboxType(Akka.Actor.Props props, Akka.Configuration.Config dispatcherConfig) { }
public System.Type GetRequiredType(System.Type actorType) { }
public bool HasRequiredType(System.Type actorType) { }
public Akka.Dispatch.MailboxType Lookup(string id) { }
public Akka.Dispatch.MailboxType LookupByQueueType(System.Type queueType) { }
public bool ProducesMessageQueue(System.Type mailboxType) { }
[Akka.Annotations.InternalApiAttribute()]
public int StashCapacity(string dispatcher, string mailbox) { }
}
public abstract class MessageDispatcher
{
Expand Down
Loading

0 comments on commit 4d124ce

Please sign in to comment.