org.apache.activemq.apollo.broker

Subscription

class Subscription extends DeliveryProducer with Dispatched

Interfaces a DispatchConsumer with a Queue. Tracks current position of the consumer on the queue, and the delivery rate so that slow consumers can be detected. It also tracks the entries which the consumer has acquired.

Linear Supertypes
Dispatched, DeliveryProducer, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. Subscription
  2. Dispatched
  3. DeliveryProducer
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Subscription (queue: Queue, consumer: DeliveryConsumer)

Type Members

  1. class AcquiredQueueEntry extends LinkedNode[AcquiredQueueEntry]

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 acquire (entry: QueueEntry): AcquiredQueueEntry

  7. var acquired : LinkedNodeList[AcquiredQueueEntry]

  8. def acquired_count : Int

  9. var acquired_size : Long

  10. def adjust_prefetch_size : (Long, Long)

  11. def advance (value: QueueEntry): Unit

    Advances the subscriptions position to the specified queue entry.

  12. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  13. def assert_executing : Unit

    Definition Classes
    Dispatched
  14. def browser : Boolean

  15. def check_consumer_stall : Unit

  16. def check_finish_close : Unit

  17. def check_load_stall : Unit

  18. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  19. def close (): Unit

  20. def collocate (value: DispatchQueue): Unit

    Definition Classes
    DeliveryProducer
  21. def connection : Option[BrokerConnection]

    Definition Classes
    DeliveryProducer
  22. val consumer : DeliveryConsumer

  23. val consumer_buffer : Int

  24. var consumer_stall_ms : Long

  25. var consumer_stall_start : Long

  26. def dispatch_queue : DispatchQueue

    Definition Classes
    Subscription → Dispatched → DeliveryProducer
  27. var enqueue_size_at_last_interval : Long

  28. var enqueue_size_per_interval : Long

  29. def eq (arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  31. def exclusive : Boolean

  32. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  33. def full : Boolean

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

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

    Definition Classes
    AnyRef → Any
  36. val id : Int

  37. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  38. var load_stall_ms : Long

  39. var load_stall_start : Long

  40. def matches (entry: Delivery): Boolean

  41. def ne (arg0: AnyRef): Boolean

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

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

    Attributes
    final
    Definition Classes
    AnyRef
  44. def offer (delivery: Delivery): Boolean

  45. def open (): Unit

  46. var pending_close_action : () ⇒ Unit

  47. var pos : QueueEntry

  48. val queue : Queue

  49. def refill_prefetch : Unit

  50. def rewind (value: QueueEntry): Unit

    Rewinds to a previously seen location.

    Rewinds to a previously seen location.. Happens when a nack occurs from another consumer.

  51. def send_buffer_size : Int

    Definition Classes
    DeliveryProducer
  52. var session : DeliverySession

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

    Attributes
    final
    Definition Classes
    AnyRef
  54. def tail_parked : Boolean

  55. def toString (): String

    Definition Classes
    Subscription → AnyRef → Any
  56. var total_ack_count : Long

  57. var total_nack_count : Long

  58. def wait (): Unit

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from Dispatched

Inherited from DeliveryProducer

Inherited from AnyRef

Inherited from Any