JMeter-Rabbit-AMQP
JMeter-Rabbit-AMQP copied to clipboard
AMQP exchange?
My amqp has a shovel that is between two exchangers and has a user limitation to not allow re-declaration of the exchange.
When this tool connects to the exchange, it tries to re declare even though it is not ticked, resulting in error. If I remove the limitation, it continues, but the bindings are lost even though they are durable.
Logs:
2017/02/16 13:58:30 INFO - jmeter.engine.StandardJMeterEngine: Running the test! 2017/02/16 13:58:30 INFO - jmeter.samplers.SampleEvent: List of sample_variables: [] 2017/02/16 13:58:30 INFO - jmeter.gui.util.JMeterMenuBar: setRunning(true,*local*) 2017/02/16 13:58:30 INFO - jmeter.engine.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group - AMQP Publisher - routing key 5156 2017/02/16 13:58:30 INFO - jmeter.engine.StandardJMeterEngine: Starting 1 threads for group Thread Group - AMQP Publisher - routing key 5156. 2017/02/16 13:58:30 INFO - jmeter.engine.StandardJMeterEngine: Thread will continue on error 2017/02/16 13:58:30 INFO - jmeter.threads.ThreadGroup: Starting thread group number 1 threads 1 ramp-up 0 perThread 0.0 delayedStart=false 2017/02/16 13:58:30 INFO - jmeter.threads.ThreadGroup: Started thread group number 1 2017/02/16 13:58:30 INFO - jmeter.engine.StandardJMeterEngine: All thread groups have been started 2017/02/16 13:58:30 INFO - jmeter.threads.JMeterThread: Thread started: Thread Group - AMQP Publisher - routing key 5156 1-1 2017/02/16 13:58:30 INFO - jmeter.services.FileServer: Stored: C:\Users\*******\Desktop\data.txt 2017/02/16 13:58:30 INFO - com.zeroclue.jmeter.protocol.amqp.AMQPSampler: Creating channel dev.public:5672 2017/02/16 13:58:30 INFO - com.zeroclue.jmeter.protocol.amqp.AMQPSampler: RabbitMQ ConnectionFactory using: virtual host: dev.public host: 10.10.10.154 port: 5672 username: dev.public password: ********** timeout: 10 heartbeat: 1 in com.zeroclue.jmeter.protocol.amqp.AMQPPublisher@49f6e843 2017/02/16 13:58:30 INFO - com.zeroclue.jmeter.protocol.amqp.AMQPSampler: Using hosts: [10.10.10.154] addresses: [10.10.10.154:5672] 2017/02/16 13:58:30 ERROR - com.zeroclue.jmeter.protocol.amqp.AMQPPublisher: Failed to initialize channel : java.net.SocketTimeoutException: connect timed out at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method) at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:589) at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:50) at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:60) at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:99) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:900) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:859) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:681) at com.zeroclue.jmeter.protocol.amqp.AMQPSampler.createChannel(AMQPSampler.java:426) at com.zeroclue.jmeter.protocol.amqp.AMQPSampler.initChannel(AMQPSampler.java:75) at com.zeroclue.jmeter.protocol.amqp.AMQPPublisher.initChannel(AMQPPublisher.java:266) at com.zeroclue.jmeter.protocol.amqp.AMQPPublisher.sample(AMQPPublisher.java:69) at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:475) at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:418) at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:249) at java.lang.Thread.run(Thread.java:745)
Logs rabbit:
Channel error on connection <0.5171.371> (10.10.10.63:54415 -> 10.10.10.154:5672, vhost: 'dev.public', user: 'dev.public'), channel 1: operation exchange.**declare** caused a channel exception access_refused: "access to exchange 'public.accountFilter' in vhost 'dev.public' refused for user 'dev.public'"