File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff 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.
Original file line number Diff line number Diff 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 ) {
You can’t perform that action at this time.
0 commit comments