autoReconnect method

@protected void autoReconnect(MqttAutoReconnect reconnectEvent)

Auto reconnect

Implementation

@protected
void autoReconnect(MqttAutoReconnect reconnectEvent) async {
  MqttLogger.log('MqttConnectionHandlerBase::autoReconnect entered');
  // If already in progress exit and we were not connected return
  if (autoReconnectInProgress! && !reconnectEvent.wasConnected) {
    return;
  }
  autoReconnectInProgress = true;
  // If the auto reconnect callback is set call it
  if (onAutoReconnect != null) {
    onAutoReconnect!();
  }

  // If we are connected disconnect from the broker.
  if (reconnectEvent.wasConnected) {
    MqttLogger.log(
        'MqttConnectionHandlerBase::autoReconnect - was connected, sending disconnect');
    sendMessage(MqttDisconnectMessage()
        .withReasonCode(MqttDisconnectReasonCode.normalDisconnection));
    connectionStatus.state = MqttConnectionState.disconnecting;
  }
  connection.disconnect(auto: true);
  connection.onDisconnected = null;
  MqttLogger.log(
      'MqttConnectionHandlerBase::autoReconnect - attempting reconnection');
  connectionStatus = await connect(server, port, connectionMessage);
  autoReconnectInProgress = false;
  if (connectionStatus.state == MqttConnectionState.connected) {
    connection.onDisconnected = onDisconnected;
    // Fire the re subscribe event.
    clientEventBus!.fire(MqttResubscribe(fromAutoReconnect: true));
    MqttLogger.log(
        'MqttConnectionHandlerBase::autoReconnect - auto reconnect complete');
    // If the auto reconnect callback is set call it
    if (onAutoReconnected != null) {
      onAutoReconnected!();
    }
  } else {
    MqttLogger.log(
        'MqttConnectionHandlerBase::autoReconnect - auto reconnect failed - re trying');
    clientEventBus?.fire(MqttAutoReconnect());
  }
}