Skip to content

Commit 9fe8378

Browse files
committed
fix: update queueOptions method return type to OptionsInterface in HasQueueOptions
1 parent b82fdb5 commit 9fe8378

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

src/Queue/Contract/HasQueueOptions.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,9 @@
22

33
namespace Spiral\RoadRunnerLaravel\Queue\Contract;
44

5+
use Spiral\RoadRunner\Jobs\OptionsInterface;
6+
57
interface HasQueueOptions
68
{
7-
public function queueOptions(): array;
9+
public function queueOptions(): OptionsInterface;
810
}

src/Queue/RoadRunnerQueue.php

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313
use Spiral\Goridge\RPC\RPCInterface;
1414
use Spiral\RoadRunner\Jobs\Jobs;
1515
use Spiral\RoadRunner\Jobs\KafkaOptions;
16-
use Spiral\RoadRunner\Jobs\KafkaOptionsInterface;
1716
use Spiral\RoadRunner\Jobs\Options;
1817
use Spiral\RoadRunner\Jobs\OptionsInterface;
1918
use Spiral\RoadRunner\Jobs\Queue\Driver;
@@ -100,14 +99,13 @@ private function getJobOverrideOptions(string|object $job): array
10099
{
101100
if (is_string($job) && class_exists($job)) {
102101
$job = app($job);
103-
104-
if ($job instanceof HasQueueOptions) {
105-
return $job->queueOptions();
106-
}
107102
}
108103

109104
if ($job instanceof HasQueueOptions) {
110-
return $job->queueOptions();
105+
$options = $job->queueOptions();
106+
if ($options instanceof Options) {
107+
return $options->toArray();
108+
}
111109
}
112110

113111
return [];

0 commit comments

Comments
 (0)