59 $typeFilter = $this->
getOption(
'type',
'' );
60 $stateFilter = $this->
getOption(
'status',
'' );
61 $stateLimit = (float)$this->
getOption(
'limit', INF );
65 $filteredTypes = $typeFilter
67 : $group->getQueueTypes();
68 $filteredStates = $stateFilter
69 ? array_intersect_key( self::STATE_METHODS, [ $stateFilter => 1 ] )
70 : self::STATE_METHODS;
74 foreach ( $filteredTypes as $type ) {
75 $queue = $group->get( $type );
76 foreach ( $filteredStates as $state => $method ) {
77 foreach ( $queue->$method() as
$job ) {
79 $this->
output( $job->toString() .
" status=$state\n" );
80 if ( ++$count >= $stateLimit ) {
86 } elseif ( $this->
hasOption(
'group' ) ) {
87 foreach ( $filteredTypes as $type ) {
88 $queue = $group->get( $type );
89 $delayed = $queue->getDelayedCount();
90 $pending = $queue->getSize();
91 $claimed = $queue->getAcquiredCount();
92 $abandoned = $queue->getAbandonedCount();
93 $active = max( 0, $claimed - $abandoned );
94 if ( ( $pending + $claimed + $delayed + $abandoned ) > 0 ) {
96 "{$type}: $pending queued; " .
97 "$claimed claimed ($active active, $abandoned abandoned); " .
104 foreach ( $filteredTypes as $type ) {
105 $count += $group->get( $type )->getSize();
107 $this->
output(
"$count\n" );