With latest version of gatling-2.2.2 Unable to use this plugin...
I have gatling-amqp_2.11:0.5 in project dependencies...
When run performance test getting the below error.
Missing or invalid dependency detected while loading class file 'AmqpProtocol.class'.
Could not access type Protocol in package io.gatling.core.config,
because it (or its dependencies) are missing. Check your build definition for
missing or conflicting dependencies. (Re-run with -Ylog-classpath to see the problematic classpath.)
A full rebuild may help if 'AmqpProtocol.class' was compiled against an incompatible version of io.gatling.core.config.
one error found
Can you help me on this one to work on gatling-2.2.2
Is there a way to define just one consumer for a scenario which spans more than one user? I have a scenario which publishes messages concurently and would like to have just one consumer to see its throughput.
Very often I get Simulation finished but the gatling actor is not stopped. Below is one of the outputs
[INFO] [GatlingSystem-akka.actor.default-dispatcher-16] [akka://GatlingSystem/user/io.gatling.core.result.writer.FileDataWriter] Message [io.gatling.core.result.writer.UserMessage] from Actor[akka://GatlingSystem/deadLetters] to Actor[akka://GatlingSystem/user/io.gatling.core.result.writer.FileDataWriter#-1654396042] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
or
[GatlingSystem-akka.actor.default-dispatcher-20] [akka://GatlingSystem/user/throttler] Message [io.gatling.core.controller.throttle.OneSecondTick$] from Actor[akka://GatlingSystem/user/throttler#-346115863] to Actor[akka://GatlingSystem/user/throttler#-346115863] was not delivered. [8] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
An example of a scenario that leads to this problem.
val messageExchange = exchange("EventExchange", "direct", autoDelete = false)
val messageQueue = queue("message_queue", durable = true, autoDelete = false)
implicit val amqpProtocol: AmqpProtocol = amqp
.host(rabbitMqHost)
.port(rabbitMqPort)
.auth(rabbitMqUser, rabbitMqPassword)
.declare(messageQueue)
.bind(messageExchange, messageQueue, routingKey = "created")
val scn = scenario("Deliver Message").exec(amqp("Consume").consume("message_queue", autoAck = true))
setUp(scn.inject(rampUsers(50) over (5 seconds)).protocols(amqpProtocol)).maxDuration(30 seconds)
I run the test in a maven build using the gatling-maven-plugin. When running scenarios that use let's say http protocol it finishes successfully.