File tree 1 file changed +22
-0
lines changed 1 file changed +22
-0
lines changed Original file line number Diff line number Diff line change @@ -323,7 +323,29 @@ public function testRateLimit() {
323
323
//and now the queue is empty
324
324
$ tmp = $ this ->QueuedTask ->requestJob ($ capabilities );
325
325
$ this ->assertEqual ($ tmp , null );
326
+ }
327
+
328
+ public function testRequeueAfterTimeout () {
329
+ $ capabilities = array (
330
+ 'task1 ' => array (
331
+ 'name ' => 'task1 ' ,
332
+ 'timeout ' => 1 ,
333
+ 'retries ' => 2 ,
334
+ 'rate ' => 0
335
+ )
336
+ );
326
337
338
+ $ this ->assertTrue ($ this ->QueuedTask ->createJob ('task1 ' , '1 ' ));
339
+ $ tmp = $ this ->QueuedTask ->requestJob ($ capabilities );
340
+ $ this ->assertEqual ($ tmp ['jobtype ' ], 'task1 ' );
341
+ $ this ->assertEqual (unserialize ($ tmp ['data ' ]), '1 ' );
342
+ $ this ->assertEqual ($ tmp ['failed ' ], '0 ' );
343
+ sleep (2 );
344
+ $ tmp = $ this ->QueuedTask ->requestJob ($ capabilities );
345
+ $ this ->assertEqual ($ tmp ['jobtype ' ], 'task1 ' );
346
+ $ this ->assertEqual (unserialize ($ tmp ['data ' ]), '1 ' );
347
+ $ this ->assertEqual ($ tmp ['failed ' ], '1 ' );
327
348
}
349
+
328
350
}
329
351
?>
You can’t perform that action at this time.
0 commit comments