@@ -257,7 +257,7 @@ public function testLazy()
257
257
], $ message ['data ' ]);
258
258
$ connection ->reject ($ message ['id ' ]);
259
259
} finally {
260
- $ redis ->del ('messenger-lazy ' );
260
+ $ redis ->unlink ('messenger-lazy ' );
261
261
}
262
262
}
263
263
@@ -295,14 +295,13 @@ public function testJsonError()
295
295
} catch (TransportException $ e ) {
296
296
$ this ->assertSame ('Malformed UTF-8 characters, possibly incorrectly encoded ' , $ e ->getMessage ());
297
297
} finally {
298
- $ redis ->del ('messenger-json-error ' );
298
+ $ redis ->unlink ('messenger-json-error ' );
299
299
}
300
300
}
301
301
302
302
public function testGetNonBlocking ()
303
303
{
304
304
$ redis = new \Redis ();
305
-
306
305
$ connection = Connection::fromDsn ('redis://localhost/messenger-getnonblocking ' , ['delete_after_ack ' => true ], $ redis );
307
306
308
307
try {
@@ -311,7 +310,7 @@ public function testGetNonBlocking()
311
310
$ this ->assertNotEmpty ($ message = $ connection ->get ());
312
311
$ connection ->reject ($ message ['id ' ]);
313
312
} finally {
314
- $ redis ->del ('messenger-getnonblocking ' );
313
+ $ redis ->unlink ('messenger-getnonblocking ' );
315
314
}
316
315
}
317
316
@@ -330,7 +329,7 @@ public function testGetAfterReject()
330
329
$ connection = Connection::fromDsn ('redis://localhost/messenger-rejectthenget ' , ['delete_after_ack ' => true ]);
331
330
$ this ->assertNotNull ($ connection ->get ());
332
331
} finally {
333
- $ redis ->del ('messenger-rejectthenget ' );
332
+ $ redis ->unlink ('messenger-rejectthenget ' );
334
333
}
335
334
}
336
335
0 commit comments