我正在尝试将RabbitMQ实现到我的Android应用程序中,但是当我尝试调用外部函数时连接丢失时,在handleDelivery
方法中有一个问题。
private fun initRabbitmq () {
factory.setUri("someURI")
subscribeThread = Thread(object : Runnable {
override fun run() {
val connection: Connection = factory.newConnection()
val channel: Channel = connection.createChannel()
val consumer: DefaultConsumer
consumer = object : DefaultConsumer(channel) {
override fun handleDelivery(consumerTag: String?, envelope: Envelope?, properties: AMQP.BasicProperties?, body: ByteArray?) {
super.handleDelivery(consumerTag, envelope, properties, body)
val msg = String(body!!, Charsets.UTF_8)
Log.e(TAG, "RabbitMQ - $msg")
showRabbitMessage(msg)
}
}
channel.basicConsume("defenders_test", true, consumer)
}
})
subscribeThread.start()
}
当函数showRabbitMessage()
被执行时连接丢失,但如果我删除它并观看日志,则消息将显示在控制台中。
知道如何从线程中获取消息吗? Thx提前!
问题是我必须从线程转移对象 - > out,并且在android中它可以通过使用Handle
对象和handleMessage()
方法来完成。