org.apache.activemq.apollo.broker.store

Store

trait Store extends ServiceTrait

The Store is service which offers asynchronous persistence services to a Broker.

Linear Supertypes
ServiceTrait, Service, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. Store
  2. ServiceTrait
  3. Service
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Abstract Value Members

  1. def add_queue (record: QueueRecord)(callback: (Boolean) ⇒ Unit): Unit

    Adds a queue.

    Adds a queue.

    This method auto generates and assigns the key field of the queue record and returns true if it succeeded.

    Attributes
    abstract
  2. def create_uow (): StoreUOW

    Creates a store uow which is used to perform persistent operations as unit of work.

    Creates a store uow which is used to perform persistent operations as unit of work.

    Attributes
    abstract
  3. def export_data (os: OutputStream, cb: (Option[String]) ⇒ Unit): Unit

    Exports the contents of the store to the provided stream.

    Exports the contents of the store to the provided stream.

    Attributes
    abstract
  4. def flush_message (messageKey: Long)(callback: ⇒ Unit): Unit

    Removes a the delivery associated with the provided from any internal buffers/caches.

    Removes a the delivery associated with the provided from any internal buffers/caches. The callback is executed once, the message is no longer buffered.

    Attributes
    abstract
  5. def get_last_queue_key (callback: (Option[Long]) ⇒ Unit): Unit

    Ges the last queue key identifier stored.

    Ges the last queue key identifier stored.

    Attributes
    abstract
  6. def get_map_entry (key: Buffer)(callback: (Option[Buffer]) ⇒ Unit): Unit

    Gets a value of a previously stored map entry.

    Gets a value of a previously stored map entry.

    Attributes
    abstract
  7. def get_prefixed_map_entries (prefix: Buffer)(callback: (Seq[(Buffer, Buffer)]) ⇒ Unit): Unit

    Gets a value of a previously stored map entry.

    Gets a value of a previously stored map entry.

    Attributes
    abstract
  8. def get_queue (queueKey: Long)(callback: (Option[QueueRecord]) ⇒ Unit): Unit

    Loads the queue information for a given queue key.

    Loads the queue information for a given queue key.

    Attributes
    abstract
  9. def get_store_status (callback: (StoreStatusDTO) ⇒ Unit): Unit

    Attributes
    abstract
  10. def import_data (is: InputStream, cb: (Option[String]) ⇒ Unit): Unit

    Imports a previous export from the input stream.

    Imports a previous export from the input stream.

    Attributes
    abstract
  11. def list_queue_entries (queueKey: Long, firstSeq: Long, lastSeq: Long)(callback: (Seq[QueueEntryRecord]) ⇒ Unit): Unit

    Loads all the queue entry records for the given queue id between the first and last provided queue sequences (inclusive).

    Loads all the queue entry records for the given queue id between the first and last provided queue sequences (inclusive).

    Attributes
    abstract
  12. def list_queue_entry_ranges (queueKey: Long, limit: Int)(callback: (Seq[QueueEntryRange]) ⇒ Unit): Unit

    Groups all the entries in the specified queue into ranges containing up limit entries big and returns those ranges.

    Groups all the entries in the specified queue into ranges containing up limit entries big and returns those ranges. Allows you to incrementally, load all the entries in a queue.

    Attributes
    abstract
  13. def list_queues (callback: (Seq[Long]) ⇒ Unit): Unit

    Gets a listing of all queue entry sequences previously added and reports them to the callback.

    Gets a listing of all queue entry sequences previously added and reports them to the callback.

    Attributes
    abstract
  14. def load_message (messageKey: Long, locator: AtomicReference[AnyRef])(callback: (Option[MessageRecord]) ⇒ Unit): Unit

    Loads a delivery with the associated id from persistent storage.

    Loads a delivery with the associated id from persistent storage.

    Attributes
    abstract
  15. def purge (callback: ⇒ Unit): Unit

    Removes all previously stored data.

    Removes all previously stored data.

    Attributes
    abstract
  16. def remove_queue (queueKey: Long)(callback: (Boolean) ⇒ Unit): Unit

    Removes a queue.

    Removes a queue. Success is reported via the callback.

    Attributes
    abstract
  17. def start (arg0: Task): Unit

    Attributes
    abstract
    Definition Classes
    Service
    Annotations
    @throws()
  18. def stop (arg0: Task): Unit

    Attributes
    abstract
    Definition Classes
    Service
    Annotations
    @throws()

Concrete Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  7. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  8. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  9. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  10. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  12. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  13. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  14. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  15. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  16. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  17. def start (func: ⇒ Unit): Unit

    Definition Classes
    ServiceTrait
  18. def stop (func: ⇒ Unit): Unit

    Definition Classes
    ServiceTrait
  19. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  20. def toString (): String

    Definition Classes
    AnyRef → Any
  21. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  22. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  23. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from ServiceTrait

Inherited from Service

Inherited from AnyRef

Inherited from Any