15
15
use MongoDB \Laravel \Queue \MongoQueue ;
16
16
17
17
use function app ;
18
- use function json_encode ;
18
+ use function json_decode ;
19
19
20
20
class QueueTest extends TestCase
21
21
{
@@ -42,17 +42,16 @@ public function testQueueJobLifeCycle(): void
42
42
$ job = Queue::pop ('test ' );
43
43
$ this ->assertInstanceOf (MongoJob::class, $ job );
44
44
$ this ->assertEquals (1 , $ job ->isReserved ());
45
- $ this ->assertEquals (json_encode ([
46
- 'uuid ' => $ uuid ,
47
- 'displayName ' => 'test ' ,
48
- 'job ' => 'test ' ,
49
- 'maxTries ' => null ,
50
- 'maxExceptions ' => null ,
51
- 'failOnTimeout ' => false ,
52
- 'backoff ' => null ,
53
- 'timeout ' => null ,
54
- 'data ' => ['action ' => 'QueueJobLifeCycle ' ],
55
- ]), $ job ->getRawBody ());
45
+ $ payload = json_decode ($ job ->getRawBody (), true );
46
+ $ this ->assertEquals ($ uuid , $ payload ['uuid ' ]);
47
+ $ this ->assertEquals ('test ' , $ payload ['displayName ' ]);
48
+ $ this ->assertEquals ('test ' , $ payload ['job ' ]);
49
+ $ this ->assertNull ($ payload ['maxTries ' ]);
50
+ $ this ->assertNull ($ payload ['maxExceptions ' ]);
51
+ $ this ->assertFalse ($ payload ['failOnTimeout ' ]);
52
+ $ this ->assertNull ($ payload ['backoff ' ]);
53
+ $ this ->assertNull ($ payload ['timeout ' ]);
54
+ $ this ->assertEquals (['action ' => 'QueueJobLifeCycle ' ], $ payload ['data ' ]);
56
55
57
56
// Remove reserved job
58
57
$ job ->delete ();
0 commit comments