Package com.swiftmq.impl.streams.comp.memory

package com.swiftmq.impl.streams.comp.memory
  • Class
    Description
    ForEachMemoryCallback
    Callback that can be registered on the forEach() method of a MemoryGroup or a GroupResult.
    ForEachMessageCallback
    Callback that can be registered on the forEach() method of a Memory.
    GroupInactivityTimeout
    A GroupInactivityTimeout can be attached to a MemoryGroup and specifies a time of inactivity (no adds to attached Memory) after which all Messages in that Memory will retire and the Memory will be closed and removed from the MemoryGroup.
    GroupResult
    Represents the result of a group operation on a Memory.
    HeapMemory
    Memory implementation that stores all Messages on the heap.
    InactivityTimeout
    InactivityTimeout can be attached to a Memory and specifies a time of inactivity (no adds to Memory) after which all Messages in that Memory will retire.
    Index
    Property Index that helds Property Values and References to Messages.
    Memory
    Abstract base class for Memories.
    MemoryBuilder
    Factory to create Memories.
    MemoryCreateCallback
    Callback that is registered at a MemoryGroup.
    MemoryGroup
    A MemoryGroup groups incoming Messages on base of the values of a Message Property (Group Property).
    MemoryRemoveCallback
    Callback that is registered at a MemoryGroup.
    QueueMemory
    Memory implementation that stores all Messages as persistent Messages in a regular Queue.
    RetirementCallback
    Callback that can be registered on a Memory.
    TempQueueMemory
    Memory implementation that stores all Messages as non-persistent Messages in a Temporary Queue.
    TxBookKeeper