Skip to content

AKrasnyatov/hw20#125

Open
AleksandKrasnyatov wants to merge 37 commits into
mainfrom
AKrasnyatov/hw20
Open

AKrasnyatov/hw20#125
AleksandKrasnyatov wants to merge 37 commits into
mainfrom
AKrasnyatov/hw20

Conversation

@AleksandKrasnyatov

Copy link
Copy Markdown

No description provided.

sleep(random_int(10, 30));
$task->finish();
} catch (Throwable $e) {
$task->cancel();

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

А как происходит reject для dlx и всего связанного?

} catch (\RuntimeException $e) {
// Сбой — reject без requeue: сообщение уходит в work.dlx, тогда retry_queue,
// отлёживается RETRY_TTL_MS и возвращается в work.queue.
$message->reject(requeue: false);

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

В handler'е выше ловится \Throwable - любое исключение, сюда мы не попадём ведь

try {
$queryResponse = $this->handler->handle(new GetTaskStatusQuery($taskId));
} catch (Throwable $exception) {
return new JsonResponse(['message' => $exception->getMessage()], 404);

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Насколько уместно использовать 404 для ошибок? Со стороны клиента не очень семантически прозрачно, что тут именно ошибка, а не url/ресурс неверный



$amqpMessage = new AMQPMessage(
body: serialize($message),

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

serialize сам по себе не отдаёт json, но заголовок указан как application/json

/**
* Routing key для всех сообщений демо (default-стиль: один ключ).
*/
public const string ROUTING_KEY = 'notification';

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Это, вероятно, осталось с прошлого ДЗ? notification семантически сюда вряд ли подходит

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants