[CAMEL-7914] MQTT Endpoint disconnects on failure. Does not reconnect

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.14.0
• Fix Version/s: 2.13.4, 2.14.2, 2.15.0
• Component/s: camel-mqtt
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Davy De Waele
• Created: 14/Oct/14 18:53
• Updated: 15/Feb/15 10:33
• Resolved: 15/Feb/15 10:33

Description

When an error occurs in the Camel MQTT endpoint, the CallbackConnection onFailure callback simply disconnects the connection.

At that point there doesn't seem to be any mechanism to reconnect to the broker.

            public void onFailure(Throwable value) {
                connection.disconnect(new Callback<Void>() {
                    public void onSuccess(Void value) {
                    }

                    public void onFailure(Throwable e) {
                        LOG.debug("Failed to disconnect from " + configuration.getHost() + ". This exception is ignored.", e);
                    }
                });
            }