使用activity方法后,Android应用程序与RabbitMQ断开连接

问题描述 投票:0回答:1

我正在尝试将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提前!

android kotlin rabbitmq
1个回答
0
投票

问题是我必须从线程转移对象 - > out,并且在android中它可以通过使用Handle对象和handleMessage()方法来完成。

© www.soinside.com 2019 - 2024. All rights reserved.