Код: Выделить всё
'bootstrap' => [
'queueSend',
'queueStat',
],
'components' => [
'queueSend' => [
'queueName' => 'queue_send',
'class' => \yii\queue\amqp_interop\Queue::class,
'driver' => yii\queue\amqp_interop\Queue::ENQUEUE_AMQP_LIB,
],
'queueStat' => [
'queueName' => 'queue_stat',
'class' => \yii\queue\amqp_interop\Queue::class,
'driver' => yii\queue\amqp_interop\Queue::ENQUEUE_AMQP_LIB,
],
]
Код: Выделить всё
Yii::$app->queueSend->push(new SendJob ($config));
Код: Выделить всё
class SendJob extends BaseObject implements JobInterface
{
public function execute($queue)
{
...
Yii::$app->queueStat->push(new SaveStatJob($config));
}
}
Код: Выделить всё
yii queue-send/listen
Собственно почему SaveStatJob выполняется в рамках другого задания и как это исправить?
yii: 2.15
yii2-queue: 2.10
enqueue/amqp-lib: 0.8.42