Я тестирую с клиентской библиотекой paho mqtt с брокерским сервисом mosquitto.org.
Мой код подключения указан ниже.
buttonConnect.setOnClickListener{ view ->
val topic = textViewTopic.text.toString()
try {
val msg = "now connecting... " + textViewUrl.text as String?
Log.d(TAG, msg)
Toast.makeText(this, msg, Toast.LENGTH_LONG).show()
client.setCallback(this)
client.connect()
client.subscribe(topic, 1)
buttonConnect.visibility = View.GONE
buttonDisconnect.visibility = View.VISIBLE
} catch (ex: MqttException) {
ex.printStackTrace()
Toast.makeText(this, "$ex", Toast.LENGTH_LONG).show()
}
}
Но когда соединение установлено, соединение теряется, как показано в журналах.
теперь подключается ... tcp: //test.mosquitto.org: 1883 connectComplete
переподключение: ложь, URI: tcp: //test.mosquitto.org: 1883 потерянное соединение
connectCompleteconnect: true, URI: tcp: //test.mosquitto.org: 1883
connectionLost connectComplete reconnect: true,
URI: tcp: //test.mosquitto.org: 1883 потерянное соединение
Вот мой полный код активности .
Что я ошибаюсь?