Module aeonics.core

Class Queue.Type

  • All Implemented Interfaces:
    Exportable, Snapshotable, java.io.Closeable, java.lang.AutoCloseable
    Enclosing class:
    Queue

    public static class Queue.Type
    extends Step.Action.Type
    This is the default entity to manage the orchestration of the different messages. While all steps are naturally queued by the Executor, this instance adds another intermediate queuing level based on the level of concurrency. Incoming messages are processed entirely before starting the next (depending on the concurrency).
    • Constructor Detail

      • Type

        public Type()