Cluster singleton to use custom mailbox and dispatcher in typed actor system

Akka Libraries Akka Cluster
, ,
1

In Java, the singleton actor in the system is initialized using the following construct:

ClusterSingleton singleton = ClusterSingleton.get(system);
ActorRef<Counter.Command> proxy =
    singleton.init(SingletonActor.of(Counter.create(), "GlobalCounter"));

Is there a way to pass a custom configuration to select custom mailbox and dispatcher ?

Typically the custom mailbox (and also dispatcher) is set in the config and the actor behavior is spawned using the config selector:

my-app {
  my-special-mailbox {
    mailbox-type = "akka.dispatch.SingleConsumerOnlyUnboundedMailbox"
  }
}

context.spawn(
    childBehavior,
    "from-config-mailbox-child",
    MailboxSelector.fromConfig("my-app.my-special-mailbox"));

context.spawn(
    behavior, "DispatcherFromConfig", DispatcherSelector.fromConfig("your-dispatcher"));
1 Like
2

akka.cluster.typed.SingletonActor#withProps (so SingletonActor.of(...).withProps(...)) should make it possible to specify dispatcher and mailbox settings for a typed singleton.

3

How would we get Props in this case? to pass into withProps(...). I was not able to find an appropriate constructor to get Props or to convert from, Config for example

4

The DispatcherSelector.fromConfig method mentioned returns an akka.actor.typed.DispatcherSelector which extends akka.actor.typed.Props so you should be able to pass that to SingletonActor#withProps()

1 Like