wikimedia /
mediawiki
| @@ 163-170 (lines=8) @@ | ||
| 160 | * @return int |
|
| 161 | * @throws JobQueueError |
|
| 162 | */ |
|
| 163 | protected function doGetDelayedCount() { |
|
| 164 | $conn = $this->getConnection(); |
|
| 165 | try { |
|
| 166 | return $conn->zSize( $this->getQueueKey( 'z-delayed' ) ); |
|
| 167 | } catch ( RedisException $e ) { |
|
| 168 | $this->throwRedisException( $conn, $e ); |
|
| 169 | } |
|
| 170 | } |
|
| 171 | ||
| 172 | /** |
|
| 173 | * @see JobQueue::doGetAbandonedCount() |
|
| @@ 177-184 (lines=8) @@ | ||
| 174 | * @return int |
|
| 175 | * @throws JobQueueError |
|
| 176 | */ |
|
| 177 | protected function doGetAbandonedCount() { |
|
| 178 | $conn = $this->getConnection(); |
|
| 179 | try { |
|
| 180 | return $conn->zSize( $this->getQueueKey( 'z-abandoned' ) ); |
|
| 181 | } catch ( RedisException $e ) { |
|
| 182 | $this->throwRedisException( $conn, $e ); |
|
| 183 | } |
|
| 184 | } |
|
| 185 | ||
| 186 | /** |
|
| 187 | * @see JobQueue::doBatchPush() |
|
