Package akka.dispatch

Class Mailboxes

  • public class Mailboxes
    extends java.lang.Object
    • Method Detail

      • DefaultMailboxId

        public static final java.lang.String DefaultMailboxId()
      • NoMailboxRequirement

        public static final java.lang.String NoMailboxRequirement()
      • BoundedCapacityPrefix

        public static final java.lang.String BoundedCapacityPrefix()
      • deadLetterMailbox

        public Mailbox deadLetterMailbox()
      • lookup

        public MailboxType lookup​(java.lang.String id)
        Returns a mailbox type as specified in configuration, based on the id, or if not defined None.
      • lookupByQueueType

        public MailboxType lookupByQueueType​(java.lang.Class<?> queueType)
        Returns a mailbox type as specified in configuration, based on the type, or if not defined None.
      • getRequiredType

        public java.lang.Class<?> getRequiredType​(java.lang.Class<? extends Actor> actorClass)
        Return the required message queue type for this class if any.
      • getMailboxRequirement

        public java.lang.Class<?> getMailboxRequirement​(com.typesafe.config.Config config)
      • getProducedMessageQueueType

        public java.lang.Class<?> getProducedMessageQueueType​(MailboxType mailboxType)
      • getMailboxType

        protected MailboxType getMailboxType​(Props props,
                                             com.typesafe.config.Config dispatcherConfig)
        Finds out the mailbox type for an actor based on configuration, props and requirements.
      • hasRequiredType

        public boolean hasRequiredType​(java.lang.Class<? extends Actor> actorClass)
        Check if this class can have a required message queue type.
      • stashCapacity

        public final int stashCapacity​(java.lang.String dispatcher,
                                       java.lang.String mailbox)
        INTERNAL API: The capacity of the stash. Configured in the actor's mailbox or dispatcher config.