@Override
public void messageArrived(String topico, MqttMessage mm) throws Exception {
msg = new String(mm.getPayload());
System.out.println("Mensagem recebida: " + msg);
if (isPlaca(msg)) {
status.setText("[STATUS] Verificando " + new String(mm.getPayload()) + " no BD");
if (getCarroByPlaca(msg) != null) {
bdres = "BDok";
c = getCarroByPlaca(msg);
status.setText("<html>[STATUS] O " + c.getModelo() + " De " + c.getNomeProprietario() + "<br>Está entrando</html>");
clienteMQTT.publicar("VisionGate/StreamChannel", bdres.getBytes(), 0);
} else {
bdres = "BDnot";
status.setText("[STATUS] A placa não foi encontrada no BD");
clienteMQTT.publicar("VisionGate/StreamChannel", bdres.getBytes(), 0);
}
}
}
“publicar”是一本出版的书。 当需要发送消息时,客户端将断开与代理的连接
目前没有回答
相关问题 更多 >
编程相关推荐