【发布时间】：2020-12-03 01:07:26
【问题描述】：
我正在将 Laravel 从 5.4.* 升级到 5.5.0。 RabbitMQ 在5.4 中工作得非常好，但现在当我尝试运行使用队列的功能时，它在日志中显示以下错误：
尝试 pushRaw 时出现 AMQP 错误：未定义索引：名称
日志中没有其他信息。这是我的.env：
RABBITMQ_HOST=localhost
RABBITMQ_PORT=5672
RABBITMQ_VHOST=/
RABBITMQ_LOGIN=test
RABBITMQ_PASSWORD=test
RABBITMQ_QUEUE=reporting
RABBITMQ_JOB_QUEUE=dev
这是我 queue.php 中的配置：
'worker' => [
'driver' => 'rabbitmq',
'factory_class' => Enqueue\AmqpLib\AmqpConnectionFactory::class,
'host' => env('RABBITMQ_HOST'),
'port' => env('RABBITMQ_PORT'),
'vhost' => env('RABBITMQ_VHOST'),
'login' => env('RABBITMQ_LOGIN'),
'password' => env('RABBITMQ_PASSWORD'),
'queue' => env('RABBITMQ_JOB_QUEUE'),
'options' => [
'exchange' => [
'name' => env('RABBITMQ_EXCHANGE_NAME', null),
/*
* Determine if exchange should be created if it does not exist.
*/
'declare' => env('RABBITMQ_EXCHANGE_DECLARE', true),
/*
* Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html
*/
'type' => env('RABBITMQ_EXCHANGE_TYPE', \Interop\Amqp\AmqpTopic::TYPE_DIRECT),
'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false),
'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true),
'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),
'arguments' => env('RABBITMQ_EXCHANGE_ARGUMENTS'),
],
'queue' => [
/*
* Determine if queue should be created if it does not exist.
*/
'declare' => env('RABBITMQ_QUEUE_DECLARE', true),
/*
* Determine if queue should be binded to the exchange created.
*/
'bind' => env('RABBITMQ_QUEUE_DECLARE_BIND', true),
/*
* Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html
*/
'passive' => env('RABBITMQ_QUEUE_PASSIVE', false),
'durable' => env('RABBITMQ_QUEUE_DURABLE', true),
'exclusive' => env('RABBITMQ_QUEUE_EXCLUSIVE', false),
'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false),
'arguments' => env('RABBITMQ_QUEUE_ARGUMENTS'),
],
],
],
这是RabbitMQ中composer.json的版本：
"vladimir-yuldashev/laravel-queue-rabbitmq": "6.0.0",
我的 Laravel 版本是 5.5.0。我试图推入队列的任务是：
\Mail::to($user->email)->queue(new MailPriceRequest($priceRequests));
这里出了什么问题？有什么帮助吗？
编辑：
这是MailPriceRequest 类：
class MailPriceRequest extends Mailable implements ShouldQueue
{
use Queueable, SerializesModels;
/**
* @var
*/
public $title;
/**
* @var
*/
public $items;
/**
* @var array
*/
public $groupedPriceRequests = [];
/**
* @var
*/
public $grouped;
/**
* @var string
*/
public $groupName = '';
/**
* @var
*/
public $emailSubject;
/**
* MailPriceRequest constructor.
* @param $transportOrders
*/
public function __construct($priceRequests)
{
$this->items = $priceRequests;
}
/**
* Build the message.
*
* @return $this
*/
public function build()
{
$this->setPriceRequests();
$this->setTitle();
$this->setGrouped();
$this->setSubject();
return $this->subject($this->emailSubject)->view('emails.price-requests.overview');
}
/**
* @return $this
*/
public function setSubject()
{
$this->emailSubject = $this->getOrderNumber();
return $this;
}
/**
* @return $this
*/
public function setGrouped()
{
$this->grouped = $this->groupedPriceRequests;
return $this;
}
/**
* @return $this
*/
public function setTitle()
{
$this->title = 'title';
return $this;
}
/**
* @return $this
*/
public function setPriceRequests()
{
$this->groupByCarrier();
return $this;
}
/**
* @return $this
*/
public function groupByCarrier()
{
$transformer = \App::make(PriceRequestMailTransformer::class);
foreach ($this->items as $priceRequest) {
if (!array_key_exists($priceRequest->carrier_name, $this->groupedPriceRequests)) {
$this->groupedPriceRequests[$priceRequest->carrier_name] = [
'price_requests' => []
];
}
$transformed = $transformer->transform($priceRequest);
$this->groupedPriceRequests[$priceRequest->carrier_name]['price_requests'][] = $transformed;
}
return $this;
}
/**
* @return string|null
*/
private function getOrderNumber()
{
if (count($this->items) > 1) {
return ' - ' . $this->items->first()->order_number . ' - and more references';
}
if (count($this->items) == 1) {
return ' - ' . $this->items->first()->order_number;
}
return null;
}
}
【问题讨论】：
-
能否提供代码
MailMailPriceRequestclass？ -
@Dmitry 我已经用
MailPriceRequest类更新了这个问题。 -
你也升级了 php 吗？还是已经在 7 点了。*
-
'name' => env('RABBITMQ_EXCHANGE_NAME', null),如果我没记错的话，指定交换名称通常是必填字段。否则为空字符串。\ -
@shinjw 没有任何区别！
标签： php laravel rabbitmq queue jobs