Skip to content

Commit c9ab482

Browse files
authored
Update RabbitQueue.php
1 parent d402f20 commit c9ab482

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/RabbitQueue.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public function push($job, $data = '', $queue = null)
6262
/**
6363
* @throws JsonException
6464
*/
65-
public function pushRaw($payload, $queue = null, array $options = [])
65+
public function pushRaw($payload, $queue = '', array $options = [])
6666
{
6767
[$destination, $exchange, $exchangeType, $attempts] = $this->publishProperties($queue, $options);
6868

@@ -400,7 +400,7 @@ private function createMessage($payload, int $attempts = 2): array
400400
];
401401
}
402402

403-
private function publishProperties(?string $queue = '', array $options = []): array
403+
private function publishProperties(string $queue = '', array $options = []): array
404404
{
405405
$queue = $this->getQueue($queue);
406406
$attempts = Arr::get($options, 'attempts') ?: 0;

0 commit comments

Comments
 (0)