169 похожих чатов

Всем доброе Подскажите, пожалуйста, как вытащить переменную 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)
}

2 ответов

15 просмотров

scastie.scala-lang.org

def Listner(callback: String => Unit) и внутри вызови в конце callback

Похожие вопросы

Обсуждают сегодня

Всем привет! Имеется функция: function IsValidChar(ch: UTF8Char): Boolean; var i: Integer; ValidChars: AnsiString; begin ValidChars := 'abcdefghijklmnopqrstuvwxyzABCDE...
Евгений
44
Ну вот просто даже давайте вот как. Какой нибудь конкретный кейс, можете в пример привести, где бч работает и приносит прикладную пользу, а не просто что бы было? Не крипту.
Alexander Andreev
22
объясните пожалуйста, почему функция не работает должным образом? вроде должно брать активное окно сравнивать его размер с размером экрана, и если есть совпадение = true прове...
JF
12
Гляньте, че бывает: Сегодня по одному проекту одной вебстудии делал проект небольшой, на их хостинге. На Modx revo. В определенный момент , работая в админке, вдруг перестал р...
Artem
7
лучше скажите, причём тут паскаль?
Alexey Kulakov
36
Но, может, есть уже проверенная? Наши требования такие: 1. Сообщения должны приходить из Инста в CRM оду 2. Должна быть возможность подключить несколько экаунтов Инстаграм. Р...
Alexander Sharoiko MSE / Александр Шаройко
12
> Копаем глубже > Следующий момент был, когда я спросил его, знает ли он JavaScript. Он ответил, что его учили работать с C#. Я тоже в университете писал на C#, но даже там мн...
Oleg Volkov
4
И никого не интересует какие пакеты кто использует. ((% Заходишь на сайт симфони и видишь поддержку Украины - по законам РФ это ж экстремизм. Только никто не отказывается от с...
Am Ambrion
11
Кто нибудь либу Zstandart использовал ? Это либа для сжатия от Цукерберга
Andrey Electron
9
Чтобы перехватить все нажимания буков на форме, надо хук ставить? Пробовал на форме ОнКейДаун, оно ловит клаву если фокус не на компоненте с вводом текста
Serjone
15
Карта сайта