-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Closed
Milestone
Description
I'm getting an exception when I'm trying to integrate in a custom mailbox/queue and my log message is confusing:
ArgumentException: produced message queue type of
[Sample.NoisyUnboundedMessageQueue] does not fulfill requirement for actor class
[Sample.Actors.SamplePersistentActor]. Must be a subclass of [Sample.NoisyUnboundedMessageQueue]
My message queue needs to be a subclass of itself? (Its just a clone of UnboundedMessageQueue, for experimentation purposes)
I traced this down to line 285-286 in Akka/Dispatch/Mailboxes.cs
if (HasRequiredType(actorType) && !actorRequirement.Value.IsAssignableFrom(mqType.Value))
throw new ArgumentException($"produced message queue type of [{mqType.Value}] does not fulfill requirement for actor class [{actorType}]." + $"Must be a subclass of [{mqType.Value}]");
This could just be me but that {mqType.Value}
at the end doesn't appear to be the correct input.