Hi, guys. When I use CallbackConnection to connect server. And another same client id connect again. I found CPU will be 70%~80% used. After reading the codes. I think that maybe about these slices:
void handleSessionFailure(Throwable error) { // Socket failure, should we try to reconnect? if( !disconnected && (mqtt.reconnectAttemptsMax<0 || reconnects < mqtt.reconnectAttemptsMax ) ) { ..... } else { // nope. handleFatalFailure(error); } }
I think transport needs to be stopped before handleFatalFailure(error).
Hi, guys. When I use CallbackConnection to connect server. And another same client id connect again. I found CPU will be 70%~80% used. After reading the codes. I think that maybe about these slices:
void handleSessionFailure(Throwable error) { // Socket failure, should we try to reconnect? if( !disconnected && (mqtt.reconnectAttemptsMax<0 || reconnects < mqtt.reconnectAttemptsMax ) ) { ..... } else { // nope. handleFatalFailure(error); } }
I think transport needs to be stopped before handleFatalFailure(error).