org.apache.activemq.apollo.broker.store

DelayingStoreSupport

trait DelayingStoreSupport extends Store with BaseService

Support class for implementing Stores which delay doing updates so that it can support potentially be canceling the update due to subsequent operation.

Linear Supertypes
BaseService, Dispatched, Store, ServiceTrait, Service, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. DelayingStoreSupport
  2. BaseService
  3. Dispatched
  4. Store
  5. ServiceTrait
  6. Service
  7. AnyRef
  8. Any
Visibility
  1. Public
  2. All

Type Members

  1. class DelayableUOW extends BaseRetained with StoreUOW

Abstract Value Members

  1. def _start (on_completed: Task): Unit

    Attributes
    protected abstract
    Definition Classes
    BaseService
  2. def _stop (on_completed: Task): Unit

    Attributes
    protected abstract
    Definition Classes
    BaseService
  3. 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
    Definition Classes
    Store
  4. 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
    Definition Classes
    Store
  5. def flush_delay : Long

    Attributes
    protected abstract
  6. 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
    Definition Classes
    Store
  7. 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
    Definition Classes
    Store
  8. def get_next_msg_key : Long

    Attributes
    protected abstract
  9. 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
    Definition Classes
    Store
  10. 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
    Definition Classes
    Store
  11. def get_store_status (callback: (StoreStatusDTO) ⇒ Unit): Unit

    Attributes
    abstract
    Definition Classes
    Store
  12. 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
    Definition Classes
    Store
  13. 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
    Definition Classes
    Store
  14. 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
    Definition Classes
    Store
  15. 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
    Definition Classes
    Store
  16. 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
    Definition Classes
    Store
  17. def purge (callback: ⇒ Unit): Unit

    Removes all previously stored data.

    Removes all previously stored data.

    Attributes
    abstract
    Definition Classes
    Store
  18. def remove_queue (queueKey: Long)(callback: (Boolean) ⇒ Unit): Unit

    Removes a queue.

    Removes a queue. Success is reported via the callback.

    Attributes
    abstract
    Definition Classes
    Store
  19. def store (uows: Seq[DelayableUOW])(callback: ⇒ Unit): Unit

    Attributes
    protected abstract

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. var _serviceFailure : Exception

    Attributes
    protected
    Definition Classes
    BaseService
  7. var _service_state : State

    Attributes
    protected
    Definition Classes
    BaseService
  8. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  9. def assert_executing : Unit

    Definition Classes
    Dispatched
  10. var cancelable_enqueue_actions : ConcurrentHashMap[(Long, Long), MessageAction]

  11. var canceled_add_message : Long

  12. var canceled_enqueue : Long

  13. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  14. var close_latency : TimeMetric

  15. val close_latency_counter : TimeCounter

  16. def create_uow (): DelayableUOW

    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.

    Definition Classes
    DelayingStoreSupportStore
  17. val dispatch_queue : DispatchQueue

    Definition Classes
    DelayingStoreSupport → Dispatched
  18. def drain_flushes : Unit

  19. def drain_uows : Unit

  20. def eq (arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  22. val event_source : CustomDispatchSource[Runnable, ListBuffer[Runnable]]

  23. def fill_store_status (rc: StoreStatusDTO): Unit

    Attributes
    protected
  24. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  25. var flush_latency : TimeMetric

  26. val flush_latency_counter : TimeCounter

  27. def flush_message (message_key: Long)(cb: ⇒ 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.

    Definition Classes
    DelayingStoreSupportStore
  28. val flush_source : CustomDispatchSource[DelayableUOW, ListBuffer[DelayableUOW]]

  29. def getClass (): java.lang.Class[_]

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

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

    Attributes
    final
    Definition Classes
    Any
  32. def key (x: QueueEntryRecord): (Long, Long)

  33. def locator_based : Boolean

    Attributes
    protected
  34. var message_load_batch_size : IntMetric

  35. val message_load_batch_size_counter : IntMetricCounter

  36. var message_load_latency : TimeMetric

  37. val message_load_latency_counter : TimeCounter

  38. var metric_canceled_enqueue_counter : Long

  39. var metric_canceled_message_counter : Long

  40. var metric_flushed_enqueue_counter : Long

  41. var metric_flushed_message_counter : Long

  42. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  43. val next_batch_id : AtomicInteger

  44. def notify (): Unit

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

    Attributes
    final
    Definition Classes
    AnyRef
  46. def on_store_requested (mr: MessageRecord): Unit

  47. val pending_stores : ConcurrentHashMap[Long, MessageAction]

  48. var range_load_latency : TimeMetric

  49. val range_load_latency_counter : TimeCounter

  50. def serviceFailure : Exception

    Definition Classes
    BaseService
  51. def service_state : State

    Definition Classes
    BaseService
  52. def start (on_completed: Task): Unit

    Attributes
    final
    Definition Classes
    BaseService → Service
  53. def start (func: ⇒ Unit): Unit

    Definition Classes
    ServiceTrait
  54. def stop (on_completed: Task): Unit

    Attributes
    final
    Definition Classes
    BaseService → Service
  55. def stop (func: ⇒ Unit): Unit

    Definition Classes
    ServiceTrait
  56. def store_completed (uows: ListBuffer[DelayableUOW]): Unit

  57. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  58. implicit def toIntMetricDTO (m: IntMetric): IntMetricDTO

    Attributes
    implicit
  59. def toString (): String

    Definition Classes
    AnyRef → Any
  60. implicit def toTimeMetricDTO (m: TimeMetric): TimeMetricDTO

    Attributes
    implicit
  61. val uow_source : CustomDispatchSource[DelayableUOW, ListBuffer[DelayableUOW]]

  62. def wait (): Unit

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from BaseService

Inherited from Dispatched

Inherited from Store

Inherited from ServiceTrait

Inherited from Service

Inherited from AnyRef

Inherited from Any