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

Question

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