---- Requests ------------------------------------------------------------------
> Global (OK=0 KO=0 )
---- JMS test -----------------------------------------------------------------
[--------------------------------------------------------------------------] 0%
waiting: 0 / active: 1 / done: 0
================================================================================
Please Have a look on below piece of code ...am i missing anything in configuration
import javax.jms._
import io.gatling.core.Predef._
import io.gatling.jms.Predef._
class BasicSimulation extends Simulation {
val sendQueueName = "xyz"
val receiveQName="pqr
val username = "abc"
val password = "xxxxxxxx"
val jndiConnectionFactoryName = "abc-pq-00"
val connectionUrl="xyz"
val msg = "abc"
val connFactory = jmsJndiConnectionFactory
.connectionFactoryName(jndiConnectionFactoryName)
.url(connectionUrl)
.credentials(username, password)
.contextFactory("com.tibco.tibjms.naming.TibjmsInitialContextFactory")
val jmsConfig = jms
.connectionFactory(connFactory)
.credentials(username, password)
.usePersistentDeliveryMode
val scn = scenario("JMS zbn test").repeat(1){
exec(jms("req reply testing").requestReply
.queue(receiveQName)
.textMessage(msg)
.property("ATULUUID", "123456789")
.jmsType("test_jms_type")
.check(simpleCheck(checkBodyTextCorrect)))
}
setUp(scn.inject(atOnceUsers(1))).protocols(jmsConfig)
def checkBodyTextCorrect(m: Message) = {
m match {
case tm: TextMessage => tm.getText == "abc"
case _ => true
}
}
}