Akka:优先级邮箱与Akka类型不工作

Question

我正在尝试创建一个自定义优先级邮箱，该邮箱具有akka类型，根据消息的类型对消息进行优先级排序。下面是我创建actor并向其发送消息的代码。但是，正在按照接收到的顺序处理消息，而不是按照自定义邮箱定义的顺序处理消息。

package com.akka.prac
import akka.actor.typed.{ActorSystem, Behavior, DispatcherSelector, Props, Settings}
import akka.actor.typed.scaladsl.Behaviors
import akka.dispatch.{PriorityGenerator, UnboundedPriorityMailbox}
import com.typesafe.config.{Config, ConfigFactory}
object PriorityMailBoxTyped extends App {
val config = ConfigFactory.load("applicationtyped.conf")
val actorSystem = ActorSystem(
MyPriorityActorTyped.receive,
"PriorityMailBox",
config,
DispatcherSelector.fromConfig("prio-dispatcher")
)
actorSystem ! DoubleMessage(6.0)
actorSystem ! IntMessage(1)
actorSystem ! DoubleMessage(5.0)
actorSystem ! IntMessage(3)
actorSystem ! StringMessage("Hello")
actorSystem ! IntMessage(5)
actorSystem ! StringMessage("I am priority actor")
actorSystem ! StringMessage(
"I process string messages first,then integer, long and others"
)
}
class MyPriorityActorMailBoxTyped(settings: Settings, config: Config)
extends UnboundedPriorityMailbox(
// Create a new PriorityGenerator,lower prio means more important
PriorityGenerator {
// Int Messages
case x: IntMessage => 1
// String Messages
case x: StringMessage => 0
// Long messages
case x: LongMessage => 2
// other messages
case x: DoubleMessage => 3
case _                => 4
}
)
trait MyMessage
case class IntMessage(x: Int) extends MyMessage
case class LongMessage(x: Long) extends MyMessage
case class StringMessage(x: String) extends MyMessage
case class DoubleMessage(x: Double) extends MyMessage
object MyPriorityActorTyped {
def receive: Behavior[MyMessage] = Behaviors.receive { (context, message) =>
message match {
case IntMessage(x)    => println(x)
case StringMessage(x) => println(x)
case LongMessage(x)   => println(x)
case DoubleMessage(x) => println(x)
case _                => println()
}
Behaviors.same
}
}

配置文件

prio-dispatcher {
mailbox-type = "com.akka.prac.MyPriorityActorMailBoxTyped"
}

同样的例子也适用于Akka Classic。我遗漏了什么?

谢谢。

Answer 1

这似乎是一个错误，现在已在2.6.14中修复。

刚刚测试过了，它可以与文档中的配置一起工作:

ActorSystem.create(Behaviors.setup(ctx -> someStaticBehavior(ctx)), "system", ConfigFactory.load("application.conf"), MailboxSelector.fromConfig("my-app.my-special-mailbox"));