From 815f6bfce1ea2cefc0408936c14a819322dee960 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cl=C3=A9ment=20Garnier?= Date: Wed, 23 Jul 2014 16:35:09 +0200 Subject: [PATCH] INT-3480: public DefaultPahoMC.setPayloadAsBytes JIRA: https://jira.spring.io/browse/INT-3480 In docs, it s said: ``` The DefaultPahoMessageConverter can be configured to return the raw byte[] in the payload by declaring it as a and setting the payloadAsBytes property. ``` http://docs.spring.io/spring-integration/docs/4.0.0.M3/reference/html/mqtt.html --- .../mqtt/support/DefaultPahoMessageConverter.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/support/DefaultPahoMessageConverter.java b/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/support/DefaultPahoMessageConverter.java index 4064a5ee96..0081d0da23 100644 --- a/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/support/DefaultPahoMessageConverter.java +++ b/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/support/DefaultPahoMessageConverter.java @@ -78,10 +78,14 @@ public class DefaultPahoMessageConverter implements MqttMessageConverter, BeanFa * * @param payloadAsBytes The payloadAsBytes to set. */ - protected final void setPayloadAsBytes(boolean payloadAsBytes) { + public void setPayloadAsBytes(boolean payloadAsBytes) { this.payloadAsBytes = payloadAsBytes; } + public boolean isPayloadAsBytes() { + return this.payloadAsBytes; + } + public DefaultPahoMessageConverter(int defaultQos, boolean defaultRetained, String charset) { this.defaultQos = defaultQos; this.defaultRetained = defaultRetained;