queueSizePendingDispatch
Returns an observable that will receive the current number of events queued for the given processorId, that are not already in-flight.
Parameters
processorId
The id of the processor to get the queue size for.