Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

AMQP exchange? #40

Open
SpyPower opened this issue Feb 16, 2017 · 0 comments
Open

AMQP exchange? #40

SpyPower opened this issue Feb 16, 2017 · 0 comments

Comments

@SpyPower
Copy link

SpyPower commented Feb 16, 2017

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.
image
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'"

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant