hasJobsWithSchedulerConstraint(SchedulerConstraint) | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
areAllConsumersIdle() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
handleIdle(JobConsumerIdleMessage) | | 97% | | 88% | 4 | 17 | 1 | 44 | 0 | 1 |
handleRunJobResult(RunJobResultMessage, JobHolder, RetryConstraint) | | 91% | | 80% | 2 | 6 | 1 | 13 | 0 | 1 |
considerAddingConsumers(boolean) | | 100% | | 100% | 0 | 6 | 0 | 21 | 0 | 1 |
isAboveLoadFactor() | | 100% | | 100% | 0 | 5 | 0 | 12 | 0 | 1 |
ConsumerManager(JobManagerThread, Timer, MessageFactory, Configuration) | | 100% | | n/a | 0 | 1 | 0 | 17 | 0 | 1 |
markJobsCancelled(TagConstraint, String[], boolean) | | 100% | | 90% | 1 | 6 | 0 | 15 | 0 | 1 |
addWorker() | | 100% | | 100% | 0 | 2 | 0 | 9 | 0 | 1 |
handleStop() | | 100% | | 100% | 0 | 4 | 0 | 11 | 0 | 1 |
isJobRunning(String) | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
addNoConsumersListener(Runnable) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
markJobsCancelled(TagConstraint, String[]) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
markJobsCancelledSingleId(TagConstraint, String[]) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
removeNoConsumersListener(Runnable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
onJobAdded() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
handleConstraintChange() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
getWorkerCount() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |