Я только что начал изучать кролик. Таким образом, в то время как просто делать некоторые основные вещи в RabbitMQ с Java клиентом подвожу по указанному ниже IssueНовое соединение не создается java-клиент rabbitmq
Exception in thread "main" java.util.concurrent.TimeoutException
at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:76)
at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:110)
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36)
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:372)
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:298)
at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:58)
at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:103)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:877)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:839)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:797)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:930)
at com.sharique.jobs.HelloWorldProducer.produce(HelloWorldProducer.java:32)
и ниже код, чтобы создать соединение
ConnectionFactory factory = new ConnectionFactory();
factory.setUsername("guest");
factory.setPassword("guest");
factory.setHost("localhost");
factory.setPort(5672);
Connection connection = factory.newConnection();
И еще одна вещь, т.е., RabbitMQ сервер работает ,
Пожалуйста, помогите
Есть ли блокирующий брандмауэр? Что делает telnet localhost 5672? Он входит? –
Не уверен, что я понял, в код клиента вы подключаетесь к локальному экземпляру RabbitMQ. Что это за хост 0.0.22.40? Поддерживает ли telnet localhost 5672? –
Я точно не знаю, что на самом деле это ... И я также проверил, брандмауэр выключен – Sharique