Hi I installed ActiveMQ in my local machine. I want to test it using gatling. I created one simulation class to test my JMS. But I am getting error shown below. Could you please provide me the answer, because it’s an urgency.
Here is My Code:
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 JmsTest extends Simulation{
val jmsConfig = jms
.connectionFactoryName(“connectionFactory”)
.url(“tcp://localhost:61616”)
.credentials(“admin”, “admin”)
.contextFactory(classOf[org.apache.activemq.jndi.ActiveMQInitialContextFactory].getName)
.listenerCount(1)
val scn = scenario(“JMS DSL test”).repeat(1) {
exec(jms(“req reply testing”)
.reqreply
.queue(“MyQueue”)
.replyQueue(“MyTopic”)
.textMessage(“Hello this is Naveen”)
)
}
setUp(scn.inject(atOnceUsers(1)))
.protocols(jmsConfig)
}
I created jndi.properties file with following code.
java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory
java.naming.provider.url = vm://localhost
connectionFactoryNames = connectionFactory
queue.MyQueue = TestJms1
topic.MyTopic = TestJms1
The error which I am getting is:
