File tree Expand file tree Collapse file tree 2 files changed +22
-3
lines changed Expand file tree Collapse file tree 2 files changed +22
-3
lines changed Original file line number Diff line number Diff line change @@ -193,14 +193,33 @@ public function peek($limit = 1)
193
193
/**
194
194
* @inheritdoc
195
195
*/
196
- public function count ()
196
+ public function countReady (): int
197
197
{
198
198
$ this ->checkClientConnection ();
199
199
return $ this ->client ->lLen ("queue: {$ this ->name }:messages " );
200
200
}
201
201
202
+ /**
203
+ * @inheritdoc
204
+ */
205
+ public function countReserved (): int
206
+ {
207
+ $ this ->checkClientConnection ();
208
+ return $ this ->client ->lLen ("queue: {$ this ->name }:processing " );
209
+ }
210
+
211
+ /**
212
+ * @inheritdoc
213
+ */
214
+ public function countFailed (): int
215
+ {
216
+ $ this ->checkClientConnection ();
217
+ return $ this ->client ->lLen ("queue: {$ this ->name }:failed " );
218
+ }
219
+
202
220
/**
203
221
* @return void
222
+ * @throws JobQueueException
204
223
*/
205
224
public function setUp ()
206
225
{
@@ -279,4 +298,4 @@ protected function connectClient()
279
298
}
280
299
return $ connected ;
281
300
}
282
- }
301
+ }
Original file line number Diff line number Diff line change 5
5
"license" : " MIT" ,
6
6
"require" : {
7
7
"ext-redis" : " *" ,
8
- "flowpack/jobqueue-common" : " ^2.0 "
8
+ "flowpack/jobqueue-common" : " ^3.0 || dev-master "
9
9
},
10
10
"autoload" : {
11
11
"psr-4" : {
You can’t perform that action at this time.
0 commit comments