This commit is contained in:
ct
2025-05-28 19:20:07 +08:00
parent 21526508b1
commit 7fcbd5f05d
19 changed files with 463 additions and 61 deletions

View File

@@ -12965,47 +12965,58 @@ public static function setConnectionName($name)
}
/**
* Release a reserved job back onto the queue after (n) seconds.
* Get the number of queue jobs that are ready to process.
*
* @param string $queue
* @param \Illuminate\Queue\Jobs\DatabaseJobRecord $job
* @param int $delay
* @return mixed
* @param string|null $queue
* @return int
* @static
*/
public static function release($queue, $job, $delay)
public static function readyNow($queue = null)
{
/** @var \Illuminate\Queue\DatabaseQueue $instance */
return $instance->release($queue, $job, $delay);
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->readyNow($queue);
}
/**
* Migrate the delayed jobs that are ready to the regular queue.
*
* @param string $from
* @param string $to
* @return void
* @static
*/
public static function migrateExpiredJobs($from, $to)
{
/** @var \Laravel\Horizon\RedisQueue $instance */
$instance->migrateExpiredJobs($from, $to);
}
/**
* Delete a reserved job from the queue.
*
* @param string $queue
* @param string $id
* @param \Illuminate\Queue\Jobs\RedisJob $job
* @return void
* @throws \Throwable
* @static
*/
public static function deleteReserved($queue, $id)
public static function deleteReserved($queue, $job)
{
/** @var \Illuminate\Queue\DatabaseQueue $instance */
$instance->deleteReserved($queue, $id);
/** @var \Laravel\Horizon\RedisQueue $instance */
$instance->deleteReserved($queue, $job);
}
/**
* Delete a reserved job from the reserved queue and release it.
*
* @param string $queue
* @param \Illuminate\Queue\Jobs\DatabaseJob $job
* @param \Illuminate\Queue\Jobs\RedisJob $job
* @param int $delay
* @return void
* @static
*/
public static function deleteAndRelease($queue, $job, $delay)
{
/** @var \Illuminate\Queue\DatabaseQueue $instance */
/** @var \Laravel\Horizon\RedisQueue $instance */
$instance->deleteAndRelease($queue, $job, $delay);
}
@@ -13018,7 +13029,8 @@ public static function deleteAndRelease($queue, $job, $delay)
*/
public static function clear($queue)
{
/** @var \Illuminate\Queue\DatabaseQueue $instance */
//Method inherited from \Illuminate\Queue\RedisQueue
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->clear($queue);
}
@@ -13031,20 +13043,35 @@ public static function clear($queue)
*/
public static function getQueue($queue)
{
/** @var \Illuminate\Queue\DatabaseQueue $instance */
//Method inherited from \Illuminate\Queue\RedisQueue
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->getQueue($queue);
}
/**
* Get the underlying database instance.
* Get the connection for the queue.
*
* @return \Illuminate\Database\Connection
* @return \Illuminate\Redis\Connections\Connection
* @static
*/
public static function getDatabase()
public static function getConnection()
{
/** @var \Illuminate\Queue\DatabaseQueue $instance */
return $instance->getDatabase();
//Method inherited from \Illuminate\Queue\RedisQueue
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->getConnection();
}
/**
* Get the underlying Redis instance.
*
* @return \Illuminate\Contracts\Redis\Factory
* @static
*/
public static function getRedis()
{
//Method inherited from \Illuminate\Queue\RedisQueue
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->getRedis();
}
/**
@@ -13057,7 +13084,7 @@ public static function getDatabase()
public static function getJobTries($job)
{
//Method inherited from \Illuminate\Queue\Queue
/** @var \Illuminate\Queue\DatabaseQueue $instance */
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->getJobTries($job);
}
@@ -13071,7 +13098,7 @@ public static function getJobTries($job)
public static function getJobBackoff($job)
{
//Method inherited from \Illuminate\Queue\Queue
/** @var \Illuminate\Queue\DatabaseQueue $instance */
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->getJobBackoff($job);
}
@@ -13085,7 +13112,7 @@ public static function getJobBackoff($job)
public static function getJobExpiration($job)
{
//Method inherited from \Illuminate\Queue\Queue
/** @var \Illuminate\Queue\DatabaseQueue $instance */
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->getJobExpiration($job);
}
@@ -13099,7 +13126,7 @@ public static function getJobExpiration($job)
public static function createPayloadUsing($callback)
{
//Method inherited from \Illuminate\Queue\Queue
\Illuminate\Queue\DatabaseQueue::createPayloadUsing($callback);
\Laravel\Horizon\RedisQueue::createPayloadUsing($callback);
}
/**
@@ -13111,7 +13138,7 @@ public static function createPayloadUsing($callback)
public static function getContainer()
{
//Method inherited from \Illuminate\Queue\Queue
/** @var \Illuminate\Queue\DatabaseQueue $instance */
/** @var \Laravel\Horizon\RedisQueue $instance */
return $instance->getContainer();
}
@@ -13125,7 +13152,7 @@ public static function getContainer()
public static function setContainer($container)
{
//Method inherited from \Illuminate\Queue\Queue
/** @var \Illuminate\Queue\DatabaseQueue $instance */
/** @var \Laravel\Horizon\RedisQueue $instance */
$instance->setContainer($container);
}