D
как-то двулично
Size: a a a
2020 August 05
Oℕ
Слышал, что если вовремя не лайкнуть, последствия могут быть
D
это про другие лайки
Oℕ
как-то двулично
Нелюбовь к обсуждению в твиттере двулична?
Oℕ
Обсуждения в этом чате породили несколько библиотек и много полезных вещей для них, помогли куче людей найти полезные штуки.
А вот в твиттере ни разу не видел, чтобы обсуждение, т.е. реплаи приводили к чему-то полезному.
Можно оставить только оповещения о статьях и событиях
А вот в твиттере ни разу не видел, чтобы обсуждение, т.е. реплаи приводили к чему-то полезному.
Можно оставить только оповещения о статьях и событиях
N
Всем доброе
Подскажите, пожалуйста, как вытащить переменную stringMessage из этой функции?
Подскажите, пожалуйста, как вытащить переменную 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)
}Oℕ
Всем доброе
Подскажите, пожалуйста, как вытащить переменную stringMessage из этой функции?
Подскажите, пожалуйста, как вытащить переменную 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)
}N
Код там публиковать?
Oℕ
Код там публиковать?
да
Oℕ
Код там публиковать?
Добиться, чтобы он скомпилировался
N
Код-то работает..
Просто никак не могу вытащить переменну - видимо она сокрыта, а как обойти это не знаю..
Просто никак не могу вытащить переменну - видимо она сокрыта, а как обойти это не знаю..
ᛒ
Код-то работает..
Просто никак не могу вытащить переменну - видимо она сокрыта, а как обойти это не знаю..
Просто никак не могу вытащить переменну - видимо она сокрыта, а как обойти это не знаю..
верни ее из метода
ᛒ
или приравнивай к какой то переменной как в джаве
N
или приравнивай к какой то переменной как в джаве
Вот так почему-то не работает
N
верни ее из метода
А так ошибка
Несоответсвие интерфейсу
Несоответсвие интерфейсу
AD
Всем доброе
Подскажите, пожалуйста, как вытащить переменную stringMessage из этой функции?
Подскажите, пожалуйста, как вытащить переменную 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 Listner(callback: String => Unit) и внутри вызови в конце callback
AD
колбечная джавка, стандард эдишн
Oℕ
Код-то работает..
Просто никак не могу вытащить переменну - видимо она сокрыта, а как обойти это не знаю..
Просто никак не могу вытащить переменну - видимо она сокрыта, а как обойти это не знаю..
Я к тому, что чтобы увеличить вероятность помощи, нужно создать воспроизводимый пример.
Т.е. так, чтобы этот пример мог скомпилировать и запустить другой.
Т.е. так, чтобы этот пример мог скомпилировать и запустить другой.
AD
перед экноледж
AD
def Listener(callback: String => Unit): 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)
callback(stringMessage)
text.acknowledge()
msg1 = stringMessage
// println(msg)
}
}
case _ => {
throw new Exception("Unhandled Message Type: " + message.getClass.getSimpleName)
}
println("msg1 :" + msg1)
}
}
}
consumer.setMessageListener(listener)
}