Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
def
ack_rates: Option[(Double, Double)]
-
-
-
def
acquired_count: Int
-
var
acquired_size: Long
-
def
adjust_prefetch_size: Unit
-
def
advance(value: QueueEntry): Unit
-
final
def
asInstanceOf[T0]: T0
-
def
assert_executing: Unit
-
def
avg_enqueue_size_per_interval: Int
-
def
browser: Boolean
-
def
check_drained: Unit
-
def
clone(): AnyRef
-
def
close(): Unit
-
def
collocate(value: DispatchQueue): Unit
-
-
-
val
consumer_buffer: Int
-
def
create_link_dto(include_metrics: Boolean = true): QueueConsumerLinkDTO
-
def
dispatch_queue: DispatchQueue
-
var
drain_watchers: List[() ⇒ Unit]
-
var
enqueue_size_at_last_interval: Long
-
var
enqueue_size_per_interval: CircularBuffer[Int]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
exclusive: Boolean
-
def
finalize(): Unit
-
def
full: Boolean
-
final
def
getClass(): Class[_]
-
def
hashCode(): Int
-
val
id: Int
-
var
idle_start: Long
-
var
idle_total: Long
-
final
def
isInstanceOf[T0]: Boolean
-
def
matches(entry: Delivery): Boolean
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
offer(delivery: Delivery): Boolean
-
def
on_drain(func: ⇒ Unit): Unit
-
def
open(): Unit
-
-
val
queue: Queue
-
def
refill_prefetch: Unit
-
def
reset_stall_timer: Long
-
def
resume: Unit
-
def
rewind(value: QueueEntry): Unit
-
def
send_buffer_size: Int
-
-
def
stall_check: Unit
-
var
stall_ms: Long
-
var
stall_start: Long
-
var
started_at: Long
-
def
suspend: Unit
-
var
suspend_count: Int
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
tail_parked: Boolean
-
def
toString(): String
-
var
total_ack_count: Long
-
var
total_ack_size: Long
-
var
total_nack_count: Long
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from Dispatched
Inherited from AnyRef
Inherited from Any
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.