Skip to content
This repository was archived by the owner on Mar 9, 2024. It is now read-only.

Commit 4d4981f

Browse files
authored
Fix for 5.4
1 parent fe6941b commit 4d4981f

File tree

1 file changed

+6
-12
lines changed

1 file changed

+6
-12
lines changed

Diff for: src/AsyncQueue.php

+6-12
Original file line numberDiff line numberDiff line change
@@ -104,28 +104,26 @@ protected function buildDatabaseRecord($queue, $payload, $availableAt, $attempts
104104
/**
105105
* Get the next available job for the queue.
106106
*
107-
* @param string|null $queue
108-
* @return \StdClass|null
107+
* @param int $id
108+
* @return DatabaseJob
109109
*/
110110
public function getJobFromId($id)
111111
{
112112
$job = $this->database->table($this->table)
113113
->where('id', $id)
114114
->first();
115115

116-
if($job) {
117-
116+
if ($job) {
118117
return new DatabaseJob(
119-
$this->container, $this, $job, $job->queue
118+
$this->container, $this, $job, $this->connectionName, $job->queue
120119
);
121120
}
122121
}
123122

124123
/**
125124
* Make a Process for the Artisan command for the job id.
126125
*
127-
* @param int $jobId
128-
* @param int $delay
126+
* @param int $id
129127
*
130128
* @return void
131129
*/
@@ -141,8 +139,7 @@ public function startProcess($id)
141139
/**
142140
* Get the Artisan command as a string for the job id.
143141
*
144-
* @param int $jobId
145-
* @param int $delay
142+
* @param int $id
146143
*
147144
* @return string
148145
*/
@@ -184,7 +181,4 @@ protected function getBackgroundCommand($cmd)
184181
return $cmd.' > /dev/null 2>&1 &';
185182
}
186183
}
187-
188-
189-
190184
}

0 commit comments

Comments
 (0)