QueueMetrics

interface QueueMetrics

A utility providing some basic insight into the number of queued events for each processor.

Functions

Link copied to clipboard
abstract fun queueSizePendingDispatch(processorId: String): Observable<Int>

Returns an observable that will receive the current number of events queued for the given processorId, that are not already in-flight.