$delay = $message->getHeader('x-delay', 10000);
$delay = abs($delay);
# 业务逻辑;
}
# 业务逻辑
try {
# 模拟真实业务耗时
sleep(1);
} catchmessage->content, $headers, $this->exchangeName)->then(
function () {
echo "重回当前队列成功\n";
},
function (Throwable $e) {
echo "重回当前队列失败: " .$sync_publish) {
throw new ServiceException('发送忘记密码邮件失败,请稍后重试');
}
```
------------
效果图:
!