100% CPU if MQTT server is temporarily down

[rgaufman]

When the MQTT server is down, Paho takes 100% CPU. Any way to change logic so it does not do this?

[rgaufman]

Any ideas how to prevent 100% CPU when MQTT server is down?

[dankozlowski]

Is your program looping while trying to send a message when the broker is not available? Could you post some example code?

[rgaufman]

No looping, just opening a connection:

        @client = PahoMqtt::Client.new(
          clean_session: @clean_session, client_id: @client_id,
          username: @username, password: @password,
          # persistent
          persistent: true, reconnect_limit: 1000, reconnect_delay: 5,
          # Keep Alives
          keep_alive: 29, ack_timeout: 120,
          # Will
          will_topic: @will_topic, will_payload: 'offline',
          will_qos: 2, will_retain: true
        )
        @client.on_connack do
          logger.info 'MQTT Connected Successfully...'
        end
        @client.connect(@ip, @port)