File tree 1 file changed +2
-2
lines changed
src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -341,7 +341,7 @@ public function testGetAfterReject()
341
341
342
342
public function testItProperlyHandlesEmptyMessages ()
343
343
{
344
- $ redisReceiver = new RedisReceiver ($ this ->connection , new Serializer ());
344
+ $ redisReceiver = new RedisReceiver ($ this ->connection , Serializer:: create ());
345
345
346
346
$ this ->connection ->add ('{"message": "Hi1"} ' , ['type ' => DummyMessage::class]);
347
347
$ this ->connection ->add ('{"message": "Hi2"} ' , ['type ' => DummyMessage::class]);
@@ -352,7 +352,7 @@ public function testItProperlyHandlesEmptyMessages()
352
352
// The consumer died during handling a message while performing xtrim in parallel process
353
353
$ this ->redis = new \Redis ();
354
354
$ this ->connection = Connection::fromDsn (getenv ('MESSENGER_REDIS_DSN ' ), ['delete_after_ack ' => true ], $ this ->redis );
355
- $ redisReceiver = new RedisReceiver ($ this ->connection , new Serializer ());
355
+ $ redisReceiver = new RedisReceiver ($ this ->connection , Serializer:: create ());
356
356
357
357
/** @var Envelope[] $envelope */
358
358
$ envelope = $ redisReceiver ->get ();
You can’t perform that action at this time.
0 commit comments