jmx старый лежал в github - обновил

Проверю так:
Пущу невысокую нагрузку, которая работает норм, а потом нагружу сеть JPERF-ом
Если начнутся те же проблемы - значит оно.

ну да звучит адекватно, еще Latency смотри в первую очередь

Ок

Всем доброе
Подскажите, пожалуйста, как вытащить переменную stringMessage из этой функции?

def Listener(): Unit = {

      val connectionFactory  = new ActiveMQConnectionFactory(activeMqUrl)
      val connection = connectionFactory.createConnection
      connection.setClientID("gatling")
      connection.start

      println("Started")

      val qsession: javax.jms.Session = connection.createSession(false, ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE)
      val queue  = qsession.createQueue("dest")
      val consumer = qsession.createConsumer(queue)
      var count = 0
      var msg : String = ""

      val listener = new MessageListener {
        def onMessage(message: Message) {
          var msg1 = ""
          message match {
            case text: BytesMessage => {

              if (message.isInstanceOf[BytesMessage] && count < 1) {

                val byteMessage = message.asInstanceOf[BytesMessage]
                var byteData = new Array[Byte](byteMessage.getBodyLength.toInt)
                byteMessage.readBytes(byteData)
                byteMessage.reset()
                var stringMessage = new String(byteData)
//                println("Received message: " + stringMessage)
                count += 1
                println("Count: " + count)

                  text.acknowledge()
                  msg1 = stringMessage
//                  println(msg)

              }
            }
            case _ => {
              throw new Exception("Unhandled Message Type: " + message.getClass.getSimpleName)
            }
              println("msg1 :" + msg1)
          }
        }
      }
      consumer.setMessageListener(listener)
    }

def Listener(): Unit = {

      val connectionFactory  = new ActiveMQConnectionFactory(activeMqUrl)
      val connection = connectionFactory.createConnection
      connection.setClientID("gatling")
      connection.start

      println("Started")

      val qsession: javax.jms.Session = connection.createSession(false, ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE)
      val queue  = qsession.createQueue("dest")
      val consumer = qsession.createConsumer(queue)
      var count = 0
      var msg : String = ""

      val listener = new MessageListener {
        def onMessage(message: Message) {
          var msg1 = ""
          message match {
            case text: BytesMessage => {

              if (message.isInstanceOf[BytesMessage] && count < 1) {

                val byteMessage = message.asInstanceOf[BytesMessage]
                var byteData = new Array[Byte](byteMessage.getBodyLength.toInt)
                byteMessage.readBytes(byteData)
                byteMessage.reset()
                var stringMessage = new String(byteData)
//                println("Received message: " + stringMessage)
                count += 1
                println("Count: " + count)

                  text.acknowledge()
                  msg1 = stringMessage
//                  println(msg)

              }
            }
            case _ => {
              throw new Exception("Unhandled Message Type: " + message.getClass.getSimpleName)
            }
              println("msg1 :" + msg1)
          }
        }
      }
      consumer.setMessageListener(listener)
    }

Никак, ибо у тебя def Listener возвращает юнит

подскажите пожалуйста по гатлингу,
приложение на socket.io, пишу скрипт.
судя по логу гатлинг подгребает при проверке ответа в качестве  matching message сообщение которое пришло раньше, чем была отправка текущего. при чем проверка получения этого сообщения уже была в предыдущем блоке exec.
поэтому, очевидно, проверка падает

Подкинули мысль что как-то через callback можно..

все можно, а зачем?))

какая задача стоит?

Это сообщение из очереди, его нужно дальше в симуляцию передать

Точнее тело сообщения - там xml лежит

а как ты это в гатлинге вызываешь?

Написал отдельный object и внутри сессии вызываю метод, который забирает одно сообщение из очереди

https://github.com/TinkoffCreditSystems/gatling-amqp-plugin а это смотрел?

Да

Я бы сделал var queueResult = new LinkedBlockingQueue<String> (); за пределами метода

И клал бы ответы туда из метода

var - плохой подход, но хоть что-то

вар не обязательно использовать даже если у тебя мутабельная коллекция

Там нет надобности в списке, специально старался уйти от этого
Там просто одна строка..