Блог

Я искал документацию по этому;

Я настроил свой connectionfactory с / RequestedHeartbeat свойством, но могу ли я в любом случае проверить, что сердцебиение действительно отправляется, не изменяя класс для добавления ведения журнала?

Любая информация приветствуется, спасибо.

Быстрый и грязный способ, который я, вероятно, использовал бы для проверки этого, — это временно добавить код, чтобы пользователь-потребитель намеренно блокировался дольше, чем интервал сердцебиения, то есть через Thread.sleep вызов, и убедиться, что сервер RabbitMQ не прерывает соединение. Затем дайте ему продолжить и убедитесь, что он действительно может продолжить, как ожидалось (т. Е. Обработать сообщение как обычно, а затем подтвердить его).

т.е. если вы установите 10-секундное сердцебиение, попросите работника-потребителя перейти в режим сна на минуту. Соединение должно оставаться активным, так как клиент Java rabbitmq должен учитывать настройку сердцебиения и отправлять сердцебиение с указанным интервалом.