File tree Expand file tree Collapse file tree 1 file changed +0
-40
lines changed
Expand file tree Collapse file tree 1 file changed +0
-40
lines changed Original file line number Diff line number Diff line change @@ -383,46 +383,6 @@ public function earliestGet()
383383 $ this ->assertCount (1 , $ this ->queue ->get ($ messageOne ->getPayload ()));
384384 }
385385
386- /**
387- * @test
388- * @covers ::get
389- */
390- public function resetStuck ()
391- {
392- $ messageOne = $ this ->getMessage (['key ' => 0 ]);
393- $ messageTwo = $ this ->getMessage (['key ' => 1 ]);
394-
395- $ this ->queue ->send ($ messageOne );
396- $ this ->queue ->send ($ messageTwo );
397-
398- //sets to running
399- $ this ->collection ->updateOne (
400- ['payload.key ' => 0 ],
401- ['$set ' => ['earliestGet ' => new UTCDateTime (time () * 1000 )]]
402- );
403- $ this ->collection ->updateOne (
404- ['payload.key ' => 1 ],
405- ['$set ' => ['earliestGet ' => new UTCDateTime (time () * 1000 )]]
406- );
407-
408- $ this ->assertSame (
409- 2 ,
410- $ this ->collection ->count (
411- ['earliestGet ' => ['$lte ' => new UTCDateTime ((int )(microtime (true ) * 1000 ))]]
412- )
413- );
414-
415- //resets and gets messageOne
416- $ this ->assertNotNull ($ this ->queue ->get ($ messageOne ->getPayload ()));
417-
418- $ this ->assertSame (
419- 1 ,
420- $ this ->collection ->count (
421- ['earliestGet ' => ['$lte ' => new UTCDateTime ((int )(microtime (true ) * 1000 ))]]
422- )
423- );
424- }
425-
426386 /**
427387 * @test
428388 * @covers ::count
You can’t perform that action at this time.
0 commit comments