【发布时间】:2018-04-19 09:50:01
【问题描述】:
我正在使用 RabbitMQ。如果出于某种原因我的发布者无法发送消息,我想重试再次发送消息。我怎样才能继续重试发布消息,直到它到达消息代理。
有什么方法可以解决这个问题吗?这是我的代码。提前致谢。
try {
channel->queue_declare($queue, false, true, false, false);
$queueMsg = new AMQPMessage($Body, array('delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT););
$channel->basic_publish($queueMsg, '', $queue);
} catch (Exception $e) {
log ("Failed to send message");
/*HERE I WANT TO RETRY SENDING MESSAGE BY CALLING basic_publish() method again!! */
}
【问题讨论】:
-
添加中间队列有一些逻辑重试消息stackoverflow.com/questions/46270322/…