When attempting to build the project, build always fails. I'm not sure how to resolve this issue. Seems to be due to the following:

[ivy:resolve] :: problems summary ::
[ivy:resolve] :::: WARNINGS
[ivy:resolve] problem while downloading module descriptor: http://repo1.maven.
org/maven2/com/thoughtworks/xstream/xstream/1.4.4/xstream-1.4.4.pom: invalid sha
1: expected=9e88db04254ffc7b513471405a97a5c57d732a9c computed=e00eebf36780667926
e3daf3d67d2a88422ffbef (234ms)
[ivy:resolve] module not found: com.thoughtworks.xstream#xstream;1.4.4

[ivy:resolve] ==== local: tried
[ivy:resolve] C:\Users\Raymond.ivy2\local\com.thoughtworks.xstream\xstream
1.4.4\ivys\ivy.xml
[ivy:resolve] -- artifact com.thoughtworks.xstream#xstream;1.4.4!xstream.jar
:
[ivy:resolve] C:\Users\Raymond.ivy2\local\com.thoughtworks.xstream\xstream
1.4.4\jars\xstream.jar
[ivy:resolve] ==== shared: tried
[ivy:resolve] C:\Users\Raymond.ivy2\shared\com.thoughtworks.xstream\xstream
\1.4.4\ivys\ivy.xml
[ivy:resolve] -- artifact com.thoughtworks.xstream#xstream;1.4.4!xstream.jar
:
[ivy:resolve] C:\Users\Raymond.ivy2\shared\com.thoughtworks.xstream\xstream
\1.4.4\jars\xstream.jar
[ivy:resolve] ==== public: tried
[ivy:resolve] http://repo1.maven.org/maven2/com/thoughtworks/xstream/xstream
/1.4.4/xstream-1.4.4.pom
[ivy:resolve] ::::::::::::::::::::::::::::::::::::::::::::::
[ivy:resolve] :: UNRESOLVED DEPENDENCIES ::
[ivy:resolve] ::::::::::::::::::::::::::::::::::::::::::::::
[ivy:resolve] :: com.thoughtworks.xstream#xstream;1.4.4: not found
[ivy:resolve] ::::::::::::::::::::::::::::::::::::::::::::::
[ivy:resolve]
[ivy:resolve]
[ivy:resolve] :: USE VERBOSE OR DEBUG MESSAGE LEVEL FOR MORE DETAILS

BUILD FAILED
C:\Users\Raymond\Documents\JMeter-Rabbit-AMQP-master\build.xml:55: impossible to
resolve dependencies:

Using the AMQP Consumer, I'm finding that this works great if the JMeter test plan only does one thing e.g.

Success Test

1. AMQP Publish - sends good message
2. AMQP Consumer - on a response queue with assertions for response message contents containing 'SUCCESS'

However if I then use a JMeter Simple Controller to group the above into a 'Success Test' then
create a second Simple Controller for 'Failure Test' that does the same only sends in a bad message.

Failure Test
3) AMQP Publish - bad message
4) AMQP Consumer on a response queue with assertions for response message containing 'FAILURE'.

Step 4 never gets the response message. That's because the AMQP Consumer from 2) is still active and there ends up being 2 consumers for the queue.

The above was all under ONE thread group, and executes serially.

So wondering how to get around this ?
How do I stop the first consumer ?

I compile the code and i put it in lib/ext however it doesnt show anywhere in Jmeter. Please help, im new in this

I have configured a JMeter test that runs both an AMQP Producer and Consumer against a local RabbitMQ instance. When the test is finished running, the AMQP Consumer is still connected to the queue.
This is true whether I run the test in GUI or command line mode.

Hi All,

I am getting "ERROR c.z.j.p.a.AMQPConsumer: Failed to initialize channel java.util.concurrent.TimeoutException: null "

Below is error stack:

ERROR c.z.j.p.a.AMQPConsumer: Failed to initialize channel
java.util.concurrent.TimeoutException: null
at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:77) ~[amqp-client-3.6.1.jar:?]
at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:111) ~[amqp-client-3.6.1.jar:?]
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:37) ~[amqp-client-3.6.1.jar:?]
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:367) ~[amqp-client-3.6.1.jar:?]
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:293) ~[amqp-client-3.6.1.jar:?]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:716) ~[amqp-client-3.6.1.jar:?]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:647) ~[amqp-client-3.6.1.jar:?]
at com.zeroclue.jmeter.protocol.amqp.AMQPSampler.createChannel(AMQPSampler.java:437) ~[JMeterAMQP.jar:?]
at com.zeroclue.jmeter.protocol.amqp.AMQPSampler.initChannel(AMQPSampler.java:79) ~[JMeterAMQP.jar:?]
at com.zeroclue.jmeter.protocol.amqp.AMQPConsumer.initChannel(AMQPConsumer.java:339) ~[JMeterAMQP.jar:?]
at com.zeroclue.jmeter.protocol.amqp.AMQPConsumer.sample(AMQPConsumer.java:64) [JMeterAMQP.jar:?]
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:491) [ApacheJMeter_core.jar:3.2 r1790748]
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:425) [ApacheJMeter_core.jar:3.2 r1790748]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:254) [ApacheJMeter_core.jar:3.2 r1790748]
at java.lang.Thread.run(Unknown Source) [?:1.8.0_131]

Kindly help and let me know how i can resolve this issue?

Thanks,
Abhishek

Hello,

I am not able to build this project. Currently, http://repo1.maven.org/maven2/ url is secured so we have to use https://repo1.maven.org/maven2/ url for downloading dependency jar file. I have changed line 68 in build.xml to use https but I am still not able to build this project successfully.

Please help me.
I have attached error screenshot for more reference.

Hey thanks a lot for this! I'm trying to use this to benchmark my consumers to see how many messages/second they can handle. I'm using a topic exchange. I don't see a way to set the message headers, so no way to use this yet. Is it possible to type the correct thing into the "message" box or am I missing something?

Even after several run, the Graph Result are not showing Throughput. It displays 0/minute Throughput for any number of hits.

On receiving a message using AMQP consumer, we have requirement to extract some JSON fields out of the message. We are using JSON PostProcessor for the same.

We are successfully able to consume message using AMQP Consumer. However, the response data seems to be always hardcoded as "OK" string, which fails JSON PostProcessor task while extracting necessary fields.

What is the issue here? How to get to the response body?

I had a problem on RPC_Load_Test.jmx. The exchange value is missing on
RCP Response configuration. I put in exchange field the value my_rpc_exchange. It's solve for me.

Hi,

Just to let you know, during my test with your plugin and rabbit MQ/pika python library I had an exception with AMQP exception. The reason was that pika is not sending any header in the reply-to message.
FYI to solve it I slightly modified formatHeaders function in com.zeroclue.jmeter.protocol.amqp.AMQPConsumer.java by wrapping the headers for loop in an if as follows :

if(headers != null){
        for (String key : headers.keySet()) {
    	    sb.append(key).append(": ").append(headers.get(key)).append("\n");
    	}
}

The AMQP consumer is reusing the same queue/exchange values for every subsequent sampler execution. This does not work for use-cases which have a dynamic work-queue to pull the mq-message from.

Hi,

Where can I get the documentation of this AMQP consumer and producer?

Kindly share the link/docs of the same.

Thanks,
Abhishek

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

Some perf tests are running slowly since queues & exchanges are being created/declared everytime initChannel is called. Could this be cached in the instance like channel is?

Missing 'app_id' and 'timestamp' properties in AMQP Publisher

When I have version 3.4.4 of the amqp-client.jar installed, it works. When I upgrade to 3.5.x, it throws an error because "AMQP.BasicProperties::setHeaders" method was removed.

https://www.rabbitmq.com/releases/rabbitmq-java-client/v3.5.0/rabbitmq-java-client-javadoc-3.5.0/com/rabbitmq/client/AMQP.BasicProperties.html

Need the ability to post headers along with the payload. Atleast a minimum of 4 Headers

There is no field to set expiration value in milliseconds.

I am load testing using the AMQP publisher and consumer. I have two separate jmx. One is REGISTER Publisher that will publish to REGISTER QUEUE. Server backend will process the message and publish to RESPONSE QUEUE. Then REGISTER Consumer will listen to the RESPONSE Queue. However, i always encounter timeout 500 for the REGISTER Consumer when i load test. Any idea why the 500 error?

Hi,
It would be very cool if I could use content of files as message content in the producer!

Cool version: Just specify name of file to send
Possible feature: Possible to specify files to include/exclude in an 'ant' style
Possible feature: Pick X files from the above set at random

Regards,
Stefan

First of all thanks for open-sourcing this very useful Jmeter plugin. While using this with amqp-client-3.3.4 version, it throws the following timeout error:

2015/05/27 14:49:16 ERROR - com.zeroclue.jmeter.protocol.amqp.AMQPPublisher: Failed to initialize channel :  java.io.IOException
    at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)
    at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)
    at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124)
    at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:374)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:590)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:563)
    at com.zeroclue.jmeter.protocol.amqp.AMQPSampler.createChannel(AMQPSampler.java:427)
    at com.zeroclue.jmeter.protocol.amqp.AMQPSampler.initChannel(AMQPSampler.java:75)
    at com.zeroclue.jmeter.protocol.amqp.AMQPPublisher.initChannel(AMQPPublisher.java:274)
    at com.zeroclue.jmeter.protocol.amqp.AMQPPublisher.sample(AMQPPublisher.java:73)
    at org.apache.jmeter.threads.JMeterThread.process_sampler(JMeterThread.java:429)
    at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:257)
    at java.lang.Thread.run(Thread.java:724)
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error
    at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)
    at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216)
    at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
    ... 10 more
Caused by: java.net.SocketTimeoutException: Timeout during Connection negotiation
    at com.rabbitmq.client.impl.AMQConnection.handleSocketTimeout(AMQConnection.java:583)
    at com.rabbitmq.client.impl.AMQConnection.access$600(AMQConnection.java:65)
    at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:558)
    ... 1 more

On little debugging, I changed the code in AMQPSampler to NOT set the virtual host parameter on connection factory if it is null. Now it does not error out.

if(getVirtualHost()!=null && !"".equals.getVirtualHost())
                factory.setVirtualHost(getVirtualHost());

Not sure why it gives the above error when it is set to null.

Thanks,
Hussain

Would be great to add "auto-delete" option to exchanges.
This option is passed to channel.exchangeDeclare in https://github.com/jlavallee/JMeter-Rabbit-AMQP/blob/master/src/main/com/zeroclue/jmeter/protocol/amqp/AMQPSampler.java#L94 as described at https://www.rabbitmq.com/api-guide.html#exchanges-and-queues
Thanks, Tim

Here is what I did

system

osx-10.6.8, jmeter-2.11 installed using brew

~/src/java/JMeter-Rabbit-AMQP [master*]$ which jmeter
/usr/local/bin/jmeter
~/src/java/JMeter-Rabbit-AMQP [master*]$ ll /usr/local/bin/jmeter
lrwxr-xr-x  1 thenrio  staff  32 Jun 11 12:40 /usr/local/bin/jmeter@ -> ../Cellar/jmeter/2.11/bin/jmeter

install

• compile source, java6
• copy jars to $JMETER_DIR/lib and $JMETER_DIR/lib/ext like so

/usr/local/Cellar/jmeter/2.11/lib [master]$ find .
.
./amqp-client-3.0.4.jar
./ext
./ext/JMeterAMQP.jar

• restart jmeter

but I can not see any amqp sampler...
what did I miss ?

( caveat: I do not know about the internals of jmeter )

Hi,

Is there a release version for the jar. As per Blackduck, the compoent version is master-20121109. But couldn't see this in the releases tab. Could you please confirm?

in build.xml change src and target version to at least 1.6 to fix this.

The example code throws the

missing class com.thoughtworks.xstream.converters.ConversionException error When trying to pull it up using GUI mode

Also throws the same error when run from terminal

I am on a machine Using Ubuntu 17.10 in case I need to change some system settings to allow this extension to work

1，修改 源码包里的build.xml中 关于 download-ivy 的 maven 配置中， http改成https；
2，同时修改 ivy.install.version 中版本由 2.3.0 修改为 2.5.0

完成上述步骤之后，便可以在本地编译；
ps：需要本地先配置好 ant

Hey,

I am trying to check how many connections can my RabbitMQ cluster handle but i see that the connections get closed automatically after some time when i am using this plugin.I modified the HEARTBEAT setting to 0 in the code but still the connections are getting closed and some connections close abruptly.Is it because of Timeout.COuld you tell me what is the unit of time (sec,ms) in AMQP_SAMPLER.TIMEOUT?

The AMQP publisher seems to work fine in a simple Thread Group. But if I try to use it in other Thread Group types (I tried with Stepping Thread Group and Concurrency Thread Group with 1 thread), then I get over 30,000 messages published instead of 1.

jmeter version: 3.2

MessageConversionException: Cannot convert from [java.lang.String] to

AMQP Consumer is not working because a deprecated class is being used.

Hi, I'm using the plugin to do some tests, thank you very much for sharing it because it is a good job. I think I have found a bug when a user uses a consumer in an auto delete queue.In my tests I have the queue with one message (see rabbitMQ picture) and after execute the AMQP Consumer in JMeter, the message is consumed but there is an error in JMeter and I can not see the result of the response.

Logs with Error Response

2017-07-20 15:48:06,446 INFO c.z.j.p.a.g.AMQPSamplerGui: AMQPSamplerGui.modifyTestElement() called, set user/pass to guest/guest on sampler com.zeroclue.jmeter.protocol.amqp.AMQPConsumer@991d1c
2017-07-20 15:48:06,446 INFO c.z.j.p.a.g.AMQPSamplerGui: AMQPSamplerGui.configure() called
2017-07-20 15:48:06,447 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2017-07-20 15:48:06,448 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2017-07-20 15:48:06,448 INFO o.a.j.g.u.JMeterMenuBar: setRunning(true, local)
2017-07-20 15:48:06,458 INFO o.a.j.e.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group
2017-07-20 15:48:06,458 INFO o.a.j.e.StandardJMeterEngine: Starting 1 threads for group Thread Group.
2017-07-20 15:48:06,458 INFO o.a.j.e.StandardJMeterEngine: Thread will continue on error
2017-07-20 15:48:06,458 INFO o.a.j.t.ThreadGroup: Starting thread group... number=1 threads=1 ramp-up=1 perThread=1000.0 delayedStart=false
2017-07-20 15:48:06,458 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2017-07-20 15:48:06,458 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2017-07-20 15:48:06,459 INFO o.a.j.t.JMeterThread: Thread started: Thread Group 1-1
2017-07-20 15:48:06,460 INFO c.z.j.p.a.AMQPSampler: Creating channel /:5672
2017-07-20 15:48:06,460 INFO c.z.j.p.a.AMQPSampler: RabbitMQ ConnectionFactory using:
virtual host: /
host: localhost
port: 5672
username: guest
password: guest
timeout: 1000000
heartbeat: 1
in com.zeroclue.jmeter.protocol.amqp.AMQPConsumer@d9dbffd
2017-07-20 15:48:06,460 INFO c.z.j.p.a.AMQPSampler: Using hosts: [localhost] addresses: [localhost:5672]
2017-07-20 15:48:07,491 INFO c.z.j.p.a.AMQPSampler: bound to:
queue: rpc-queue-reply-test
exchange:
exchange(D)? false
routing key: rpc-queue-reply-test
arguments: {}
2017-07-20 15:48:07,492 INFO c.z.j.p.a.AMQPConsumer: Creating consumer
2017-07-20 15:48:07,492 INFO c.z.j.p.a.AMQPConsumer: Starting basic consumer
2017-07-20 15:48:07,495 ERROR o.a.j.t.JMeterThread: Error while processing sampler: 'RPC Response'.
java.lang.NullPointerException: null
at com.zeroclue.jmeter.protocol.amqp.AMQPConsumer.formatHeaders(AMQPConsumer.java:357) ~[JMeterAMQP.jar:?]
at com.zeroclue.jmeter.protocol.amqp.AMQPConsumer.sample(AMQPConsumer.java:122) ~[JMeterAMQP.jar:?]
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:491) ~[ApacheJMeter_core.jar:3.2 r1790748]
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:425) [ApacheJMeter_core.jar:3.2 r1790748]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:254) [ApacheJMeter_core.jar:3.2 r1790748]
at java.lang.Thread.run(Unknown Source) [?:1.8.0_131]
2017-07-20 15:48:07,496 INFO o.a.j.t.JMeterThread: Thread is done: Thread Group 1-1
2017-07-20 15:48:07,496 INFO o.a.j.t.JMeterThread: Thread finished: Thread Group 1-1
2017-07-20 15:48:07,496 INFO c.z.j.p.a.AMQPSampler: AMQPSampler.threadFinished called
2017-07-20 15:48:07,510 INFO o.a.j.e.StandardJMeterEngine: Notifying test listeners of end of test
2017-07-20 15:48:07,510 INFO o.a.j.g.u.JMeterMenuBar: setRunning(false, local)