feat: improved RabbitMQ driver#1129
feat: improved RabbitMQ driver#1129sav-da wants to merge 10 commits intouserver-framework:developfrom
Conversation
- added headers to ConsumedMessage - added headers to Envelop - added heartbeat to queue
- added tests
|
Обнаружил баг, занимаюсь доработками |
|
изначальный метод конвертации работал некорректно для любых типов кроме строк |
|
@Malevrovich я в течении следующей недели подготовлю полноценную реализацию приведу к полноценной реализации. P.S. приношу извенения за прошедшее потраченное время. впредь постараюсь делать более качественные изменения |
Всё нормально, главное, что результат вырисовывается. Будем рады принять доработки |
Malevrovich
left a comment
Malevrovich
left a comment
There was a problem hiding this comment.
Еще давайте добавим в функциональные тесты
userver/rabbitmq/function_tests
Проверку работы хедеров и проверку работы хартбита
Malevrovich
left a comment
Malevrovich
left a comment
There was a problem hiding this comment.
Осталось немного мелочей. Включу прогон тестов, если падения будут относиться к изменениям, то их надо будет исправить
| assert _strip_headers(response.json()) == MESSAGES | ||
|
|
||
|
|
||
| async def test_rabbitmq_heartbeat_reconnects(testpoint, service_client, gate): |
There was a problem hiding this comment.
Если вдруг отключить/сломать хартбит, то почему тест должен начать проваливаться?
| } | ||
|
|
||
| void AmqpConnectionHandler::OnConnectionCreated(AmqpConnection* connection, engine::Deadline deadline) { | ||
| connection_ = connection; |
There was a problem hiding this comment.
Давайте на всякий случай поставим сюда
UINVARIANT(connection_ == nullptr)
Если вдруг где-то в недрах будет баг и OnConnectionCreated вызовется два раза, то будет очень тяжело обнаружить
3 participants
#137
Note: by creating a PR or an issue you automatically agree to the CLA. See CONTRIBUTING.md. Feel free to remove this note, the agreement holds.