Невозможно получить сообщение из очереди через jmeter (потребительский сэмплер amqp) - PullRequest
0 голосов
/ 08 ноября 2019

Я пытался получить сообщение с именем очереди, обменом и ключом маршрутизации через jmeter, но обнаружил следующую ошибку

2019-11-06 14: 53: 29,326 ОШИБКА czjpaAMQPConsumer: Не удалось инициализировать каналjava.io.IOException: пусто в com.rabbitmq.client.impl.AMQChannel.wrap (AMQChannel.java:106) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.AMQChannel.wrap (AMQChannel.java:102) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc (AMQChannel.java:124) ~ [amqp-client-3.6. 1.jar :?] в com.rabbitmq.client.impl.ChannelN.queueDeclare (ChannelN.java:844) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.ChannelN. queueDeclare (ChannelN.java:61) ~ [amqp-client-3.6.1.jar :?] в com.zeroclue.jmeter.protocol.amqp.AMQPSampler.initChannel (AMQPSampler.java:90) ~ [JMeterAMQP.jar :? ] в com.zeroclue.jmeter.protocol.amqp.AMQPConsumer.initChannel (AMQPConsumer.java:339) ~ [JMeterAMQP.jar :?] в com.zeroclue.jmeter.protocol.amqp.AMQPConsumer.sample (AMQPConsumer.jja: 64) [JMeterAMQP.jar :?] в org.apache.jmeter.threads.JMeterThread.doSampling (JMeterThread.java:622) [ApacheJMeter_core.jar: 5.0 r1840935] в org.apache.jmeter.threads.JexteSample(JMeterThread.java:546) [ApacheJMeter_core.jar: 5.0 r1840935] в org.apache.jmeter.threads.JMeterThread.processSampler (JMeterThread.java:486) [ApacheJMeter_core.jar: 5.0 r18409s. .JMeterThread.run (JMeterThread.java:253) [ApacheJMeter_core.jar: 5.0 r1840935] в java.lang.Thread.run (Thread.java:748) [?: 1.8.0_191] Вызывается: com.rabbitmq.client. ShutdownSignalException: ошибка канала;Метод протокола: #method (reply-code = 406, reply-text = PRECONDITION_FAILED - неэквивалентный arg 'x-dead-letter-exchange' для очереди '' в vhost '': не получен, но текущим является значение 'dead-letter'типа 'longstr', идентификатор класса = 50, идентификатор метода = 10) в com.rabbitmq.utility.ValueOrException.getValue (ValueOrException.java:67) ~ [amqp-client-3.6.1.jar :?] вcom.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue (BlockingValueOrException.java:33) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.AMQChannel $ BlockingRpcContinuation.Qhanly) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.AMQChannel.privateRpc (AMQChannel.java:226) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc (AMQChannel.java:118) ~ [amqp-client-3.6.1.jar:?]

Итак, пытался получать сообщения только с ключом маршрутизациии обмен ключами (без имени очереди), но для которых я получаю следующую ошибку.

2019-11-06 15: 14: 46,072 ОШИБКАczjpaAMQPConsumer: не удалось инициализировать канал java.io.IOException: null at com.rabbitmq.client.impl.AMQChannel.wrap (AMQChannel.java:106) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.AMQChannel.wrap (AMQChannel.java:102) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.ChannelN.basicConsume (ChannelN.java:1119) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.ChannelN.basicConsume (ChannelN.java:1087) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq. client.impl.ChannelN.basicConsume (ChannelN.java:1071) ~ [amqp-client-3.6.1.jar :?] в com.zeroclue.jmeter.protocol.amqp.AMQPConsumer.sample (AMQPConsumer.java:73) [JMeterAMQP.jar :?] в org.apache.jmeter.threads.JMeterThread.doSampling (JMeterThread.java:622) [ApacheJMeter_core.jar: 5.0 r1840935] в org.apache.jmeter.threads.JMeterThread.ThageMext.exage.exa546) [ApacheJMeter_core.jar: 5.0 r1840935]в org.apache.jmeter.threads.JMeterThread.processSampler (JMeterThread.java:486) [ApacheJMeter_core.jar: 5.0 r1840935] в org.apache.jmeter.threads.JMeterThread.run (JMeterThread.javaJMejejarjarjarjar3253): 5.0 r1840935] at java.lang.Thread.run (Thread.java:748) [?: 1.8.0_191] Причина: com.rabbitmq.client.ShutdownSignalException: ошибка канала;Метод протокола: #method (код ответа = 404, текст ответа = NOT_FOUND - ранее не объявленная очередь, идентификатор класса = 60, идентификатор метода = 20) в com.rabbitmq.utility.ValueOrException.getValue (ValueOrException.java:67) ~ [amqp-client-3.6.1.jar :?] на com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue (BlockingValueOrException.java:33) ~ [amqp-client-3.6.1.jar :?] на ком. rabbitmq.client.impl.AMQChannel $ BlockingRpcContinuation.getReply (AMQChannel.java:361) ~ [amqp-client-3.6.1.jar :?] в com.rabbitmq.client.impl.ChannelN.basicConsume (ChannelN.java:11) ~ [amqp-client-3.6.1.jar:?]

Не могли бы вы рассказать нам, как использовать сообщение для очереди, для которой в JMeter настроен обмен мертвыми буквами?

...