Hi all
If you want to test JMS through the Gatling API - you can now try this out - https://github.com/jasonk000/gatling-jms
There’s still a bit to do to round it out (more in the checks API, and create some unit test coverage), and please raise any issues if you see any. It’s not extensively tested at this point. It’s built against 2.0.0-M3a.
Thanks @slandelle and the Gatling team for putting such a great tool together and for your help getting going. Much appreciated.
Thanks
Jason
Thank you very much for contributing to the project. That’s a very cool add-on.
Cheers
Nicolas
Very nice!
I’ll try to do some review in the next weeks. Do you have a sample that can be easily set up?
Stéphane
Hi Stephane -
You can see an example here - https://github.com/jasonk000/gatling-jms#example
Or were you looking for an end to end demo of how to set up (eg: setting up a jms broker etc).
Thanks
Jason
The second one (lazy mode) 
Other questions: why did you choose FFMQ over other brokers? Is it particularly fast? Is it because you’re familiar with it? Is the project active? Will it support JMS2?
Hi Stephane
In my case, I chose FFMQ because it is simple and lightweight to set up (unzip and run). No need to configure queues manually. It claims to be fast, project does not seem active, and does not currently support Jms2 (though Jms2 should be backwards compatible).
By way of analogy, you can use Gatling to test HTTP whether you run on Apache or Microsoft IIS, Nginx, Websphere, etc. The same applies here to the JMS provider. The JMS provider is (almost) a part of hosting the service, so you have to take the JMS provider platform into account - but really you’re aiming to test the performance of your application components connected to it. So - asking why I chose FFMQ as my example is akin to asking why you choose a specific server for your tests, it doesn’t matter so much :).
JMS is an API spec and there are a number of brokers which implement the spec [1]. Whichever JMS provider you use is up to you, just change the protocol and it will work.
I’ll write a proper blog article at some point but till then feel free to ask more questions.
Thanks
Jason
[1] http://en.wikipedia.org/wiki/Java_Message_Service#Provider_implementations
[2] https://github.com/jasonk000/examples/tree/master/jms
Sorry, I didn’t properly read your code at the time I wrote this email and thought you had a compile-time dep to FFMQ.
Hi All,
I am investigating the possibility of using Gatling to test JMS application which uses ActiveMQ.
I have a couple of questions:
Many thanks,
Natalie
Hi,
Hi Pierre DAL-PRA,
When I’m testing with ActiveMQ it throws me the following error:
I think that the contextFactory name is wrong, but I can’t find any that workds…Do you have any working example with ActiveMQ that you can share?
Thanks
val jmsConfig = jms
.connectionFactoryName(ActiveMQConnectionFactory.DEFAULT_BROKER_URL)
.url(“tcp://localhost:61616”)
.contextFactory(“org.apache.activemq.jndi.ActiveMQInitialContextFactory”)
.listenerCount(1)
[ERROR] [12/29/2014 10:38:11.668] [GatlingSystem-akka.actor.default-dispatcher-3] [akka://GatlingSystem/user/jmsReqReply-3] scheme failover not recognized
akka.actor.ActorInitializationException: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:164)
at akka.actor.ActorCell.create(ActorCell.scala:596)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
at akka.dispatch.Mailbox.run(Mailbox.scala:220)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: javax.naming.NamingException: scheme failover not recognized
at org.apache.activemq.jndi.ReadOnlyContext.lookup(ReadOnlyContext.java:221)
at javax.naming.InitialContext.lookup(InitialContext.java:411)
at io.gatling.jms.client.SimpleJmsClient.(SimpleJmsClient.scala:58)
at io.gatling.jms.JmsReqReplyAction.(JmsReqReplyAction.scala:49)
at io.gatling.jms.JmsReqReplyActionBuilder$$anonfun$build$1.apply(JmsReqReplyActionBuilder.scala:31)
at io.gatling.jms.JmsReqReplyActionBuilder$$anonfun$build$1.apply(JmsReqReplyActionBuilder.scala:31)
at akka.actor.TypedCreatorFunctionConsumer.produce(Props.scala:343)
at akka.actor.Props.newActor(Props.scala:252)
at akka.actor.ActorCell.newActor(ActorCell.scala:552)
at akka.actor.ActorCell.create(ActorCell.scala:578)
… 10 more
Hi,
In your example, you’re mixing the ConnectionFactory name with the URL.
And ActiveMQ’s DEFAULT_BROKER_URL is a valid URL, but not a valid JNDI path.
This is a working example of ActiveMQ usage with Gatling’s JMS support, which we use in your tests: https://github.com/gatling/gatling/blob/master/gatling-jms/src/test/scala/io/gatling/jms/integration/JmsMockingSpec.scala#L40
Cheers,
Pierre
Hi Pierre,
Thanks for the example, after changing to connectionFactoryName(“ConnectionFactory”) it’s not failing on that exception anymore.
However I’m still not able to run the test to completion:
Caused by: java.lang.UnsupportedOperationException: There were no requests sent during the simulation, reports won’t be generated
My ActiveMQ server have nothing special, I’ve just installed and thats it. Should I configure anything in order to have this testnig running ?
Should I do anything with the MQ server ?
code:
package computerdatabase
import net.timewalker.ffmq3.FFMQConstants
import io.gatling.core.Predef._
import io.gatling.jms.Predef._
import scala.concurrent.duration._
import io.gatling.core.Predef._
import javax.jms._
import org.apache.activemq.ActiveMQConnectionFactory
class JMS10k extends Simulation {
val duration = Integer.getInteger(“duration”, 60).toInt
def jmsConfig = jms
.connectionFactoryName(“ConnectionFactory”)
.url(“tcp://localhost:61616”)
.contextFactory(classOf[org.apache.activemq.jndi.ActiveMQInitialContextFactory].getName)
.listenerCount(1)
.usePersistentDeliveryMode
val scn = scenario(“JMS DSL test”).repeat(0) {
exec(
jms(“req reply testing”).reqreply
.queue(“queueName”)
.replyQueue(“responseQueue”)
.textMessage(“hello from gatling jms dsl”)
.property(“test_header”, “test_value”)
.check(simpleCheck(checkBodyTextCorrect)))
}
setUp(scn.inject(rampUsersPerSec(10) to 1000 during (10 seconds)))
.protocols(jmsConfig)
def checkBodyTextCorrect(m: Message) = {
m match {
case tm: TextMessage => tm.getText == “HELLO FROM GATLING JMS DSL”
case _ => false
}
}
}
logs:
[INFO] Scanning for projects…
[INFO]
[INFO] Using the builder org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder with a thread count of 1
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Building gatling-maven-plugin-demo 2.1.1
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] — gatling-maven-plugin:2.1.1:execute (default-cli) @ gatling-maven-plugin-demo —
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/C:/Users/x/.m2/repository/ch/qos/logback/logback-classic/1.1.2/logback-classic-1.1.2.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/C:/Users/x/.m2/repository/org/apache/activemq/activemq-all/5.8.0/activemq-all-5.8.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
12:15:52,000 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback.groovy]
12:15:52,000 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [logback-test.xml] at [file:/C:/opt/scala_workspace/gatling-maven-plugin-demo/target/test-classes/logback-test.xml]
12:15:52,001 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs multiple times on the classpath.
12:15:52,001 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs at [file:/C:/opt/scala_workspace/gatling-maven-plugin-demo/target/test-classes/logback-test.xml]
12:15:52,001 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs at [file:/C:/opt/scala_workspace/gatling-maven-plugin-demo/src/test/resources/logback-test.xml]
12:15:52,090 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - debug attribute not set
12:15:52,102 |-INFO in ch.qos.logback.classic.joran.action.LoggerContextListenerAction - Adding LoggerContextListener of type [ch.qos.logback.classic.jul.LevelChangePropagator] to the object stack
12:15:52,128 |-INFO in ch.qos.logback.classic.jul.LevelChangePropagator@37fcdbc5 - Propagating DEBUG level on Logger[ROOT] onto the JUL framework
12:15:52,128 |-INFO in ch.qos.logback.classic.joran.action.LoggerContextListenerAction - Starting LoggerContextListener
12:15:52,128 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - About to instantiate appender of type [ch.qos.logback.core.ConsoleAppender]
12:15:52,131 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as [CONSOLE]
12:15:52,140 |-INFO in ch.qos.logback.core.joran.action.NestedComplexPropertyIA - Assuming default type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property
12:15:52,197 |-INFO in ch.qos.logback.classic.joran.action.RootLoggerAction - Setting level of ROOT logger to WARN
12:15:52,197 |-INFO in ch.qos.logback.classic.jul.LevelChangePropagator@37fcdbc5 - Propagating WARN level on Logger[ROOT] onto the JUL framework
12:15:52,197 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction - Attaching appender named [CONSOLE] to Logger[ROOT]
12:15:52,198 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - End of configuration.
12:15:52,200 |-INFO in ch.qos.logback.classic.joran.JoranConfigurator@39c07f3a - Registering current configuration as safe fallback point
SLF4J: Actual binding is of type [ch.qos.logback.classic.util.ContextSelectorStaticBinder]
Simulation computerdatabase.JMS10k started…
val scn = scenario(“JMS DSL test”).repeat(0) : That is your problem.
Your thousands of users are executing a scenario which does absolutely nothing. since the loop never get executed. repeat(0) is a nonsense.
And so Gatling complains during the reports generation that there was no requests executed in your scenario.
Hello,
M trying to test JMS application which uses TIBCO queues, could you please elaborate about integration of Gatling with TIBCO jars.
Regards,
Akhila begum
Hi All,
is there any way in Gatling to use JMS Protocol to test the IBM Websphere MQ, if so can you please let me know how we can do it
Thanks in Advance…!!!
Regards,
Venkatesh Nayak