Jmeter publisher subscriber for ActiveMQ AMQP protocol

Recently I was assigned task to evaluate performance of ActiveMQ AMQP protocol [1]. ActiveMQ supports AMQP v1.0 specification and it is completely different from previous versions of AMQP specification (0.10, 0.9.1, 0.9 ..). AMQP v1.0 support added to ActiveMQ  by Apache Qpid Proton. Let's see how we can connected to ActiveMQ broker with Jmeter.

Start ActiveMQ broker. Please note that AMQP supports added to ActiveMQ version 5.8 onward. I had apache-activemq-5.10.0 distribution.

Go to bin folder and start broker by executing activemq shell script.

~/apache-activemq-5.10.0/bin$ ./activemq start

This would start broker in background and you can see logs by tail log file.

~/apache-activemq-5.10.0/data$ tailf activemq.log

AMQP listening in 5672 port by default. You can change default AMQP port by editing AMQP transportConnector in activemq.xml.

<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

Now we'll go through how to create Jmeter script. I am using apache-jmeter-2.7. You need to copy following jar files to lib folder of Jmeter. 

activemq-all-5.10.0.jar

geronimo-jms_1.1_spec-1.1.1.jar

qpid-amqp-1-0-client-0.26.jar

qpid-amqp-1-0-client-jms-0.26.jar

qpid-amqp-1-0-common-0.26.jar

Above libraries would provide necessary classes to execute test plan in Jmeter.

Next we need to create a property file which contain jndi names to register AMQP connection factories, queue/topic names. I created file called qpid.properties in apache-jmeter-2.7 folder and added following entries.

# register some connection factories
# connectionfactory.[jndiname] = [ConnectionURL - amqp://username:password@host:port]
connectionfactory.QueueConnectionFactory = amqp://admin:password@localhost:5672
connectionfactory.TopicConnectionFactory = amqp://admin:password@localhost:5672

# register some queues in JNDI using the form
# queue.[jndiName] = [physicalName]
queue.myQueue = myQueue

# register some topics in JNDI using the form
# topic.[jndiName] = [physicalName]
topic.myTopic = myTopic

If you have already worked with previous version of AMQP protocol, you may realize that broker url is completely different. There are no Virtual-hosts, Exchanges, Bindings according to AMQP v1.0. Therefore broker url also changed according to that. 

Now start Jmeter by executing jmeter.sh in bin folder.

~/apache-jmeter-2.7/bin$ ./jmeter.sh

Let's create test plan for subscriber. R-click Test Plan -> Add -> Thread (Users) -> Thread Group. I set name to Thread Group as Subscriber and Loop Count to 100.

R-click Thread Group (Subscriber) -> Add -> Sampler -> JMS Subscriber. Set following properties.

Initial Context Factory - org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory
Provider URL - /home/indika/demo-zone/apache-jmeter-2.7/qpid.properties
Connection Factory - QueueConnectionFactory
Destination - myQueue

Make sure you provide same jndiName specified above for Connection Factory and Destination.

Let's add Summary Report to view result. R-click Thread Group (Subscriber) -> Add -> Listener -> Summary Report

Now we'll create test plan for publisher. Start another instance of Jmeter by executing jmeter.sh in bin folder.

~/apache-jmeter-2.7/bin$ ./jmeter.sh

R-click Test Plan -> Add -> Thread (Users) -> Thread Group. I set name to Thread Group as Publisher and Loop Count to 100.

R-click Thread Group (Publisher) -> Add -> Sampler -> JMS Publisher. Set following properties.

Initial Context Factory - org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory
Provider URL - /home/indika/demo-zone/apache-jmeter-2.7/qpid.properties
Connection Factory - QueueConnectionFactory
Destination - myQueue

Set any message to publish in given text area.

Let's add Summary Report to view result. R-click Thread Group (Publisher) -> Add -> Listener -> Summary Report

Now you can execute both test plans. First start subscriber test plan by pressing start button in Jmeter. Next start publisher test plan. You could see the result of both in summary report.

[1] http://activemq.apache.org/amqp.html
[2] http://qpid.apache.org/proton