Моя простая ошибка клиента Java RabbitMQ: (Сообщение об исключении: сброс соединения) - PullRequest
Новая
       41

Моя простая ошибка клиента Java RabbitMQ: (Сообщение об исключении: сброс соединения)

0 голосов
/ 10 июля 2019

У меня есть клиент RabbitMQ на Java, который прослушивает входящие уведомления для их обработки (версия клиента RabbitMQ Java 5.5.1).После нескольких месяцев бесперебойной работы, вдруг вчера я увидел эту ошибку, после которой не было получено ни одного сообщения: 

[AMQP Connection 10.233.44.138:5672] WARN com.rabbitmq.client.impl.ForgivingExceptionHandler - An unexpected connection driver error occured (Exception message: Connection reset)

В чем причина этой ошибки?Как устранить его снова? 

ConnectionFactory factory = new ConnectionFactory();
factory.setHost(rabbitMqHost);
factory.setUsername(rabbitMqUser);
factory.setPassword(rabbitMqPass);
factory.setPort(rabbitMqPort);
factory.setVirtualHost("/");

Connection connection = factory.newConnection();
final Channel channel = connection.createChannel();
channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
String queueName = channel.queueDeclare().getQueue();
channel.queueBind(queueName, EXCHANGE_NAME, "");
logger.info("t3- Listening to RabbitMQ notifications...");

channel.basicConsume(queueName, false, new DefaultConsumer(channel) {
    @Override
    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
            byte[] body) throws IOException {
        // (process the message components here ...)
        final String message = new String(body, "UTF-8");


        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
        }
                ParseStatusMessage(message);
    }
});

}

...