[CAMEL-5411] MQTT Endpoint does not correctly return the MQTT-Payload

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.10.0
• Fix Version/s: 2.10.1, 2.11.0
• Component/s: camel-mqtt

Environment

Linux 64bit, JDK 1.6, Mosquitto MQTT Broker

• Estimated Complexity: Moderate
• Assignee: Robert Davies
• Reporter: Ralf Kornberger
• Created: 29/Jun/12 13:02
• Updated: 15/Aug/12 17:27
• Resolved: 15/Aug/12 17:27

Description

MQTT Endpoint does not correctly return the MQTT-Payload. It returns the whole MQTT Message (header + payload).

The bug is in line 89 of MQTTEndpoint.java (version 2.11, but also in 2.10)

exchange.getIn().setBody(body.getData());

must become

exchange.getIn().setBody(body.toByteArray());

because getData() ignores the offset (to skip the MQTT header) set in the body byte array.