Skip to content

Commit 72d2432

Browse files
authored
Fixed implicitly nullable params (#6616)
1 parent bac68ba commit 72d2432

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/Driver/DriverInterface.php

+2-2
Original file line numberDiff line numberDiff line change
@@ -48,12 +48,12 @@ public function consume(): void;
4848
/**
4949
* Reload failed message into waiting queue.
5050
*/
51-
public function reload(string $queue = null): int;
51+
public function reload(?string $queue = null): int;
5252

5353
/**
5454
* Delete all failed message from failed queue.
5555
*/
56-
public function flush(string $queue = null): bool;
56+
public function flush(?string $queue = null): bool;
5757

5858
/**
5959
* Return info for current queue.

src/Driver/RedisDriver.php

+2-2
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ public function fail(mixed $data): bool
109109
return false;
110110
}
111111

112-
public function reload(string $queue = null): int
112+
public function reload(?string $queue = null): int
113113
{
114114
$channel = $this->channel->getFailed();
115115
if ($queue) {
@@ -127,7 +127,7 @@ public function reload(string $queue = null): int
127127
return $num;
128128
}
129129

130-
public function flush(string $queue = null): bool
130+
public function flush(?string $queue = null): bool
131131
{
132132
$channel = $this->channel->getFailed();
133133
if ($queue) {

0 commit comments

Comments
 (0)