From b5b1c58f17f1cc2d5421eb82ebe81030f2b3c7af Mon Sep 17 00:00:00 2001 From: Howard Gao Date: Tue, 22 Aug 2017 15:27:10 +0800 Subject: [PATCH] NO-JIRA Fix checkstyle --- .../activemq/artemis/mqtt/example/InterceptorExample.java | 2 +- .../activemq/artemis/mqtt/example/SimpleMQTTInterceptor.java | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/InterceptorExample.java b/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/InterceptorExample.java index 4fb5abf5300..e72c93f7948 100644 --- a/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/InterceptorExample.java +++ b/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/InterceptorExample.java @@ -54,7 +54,7 @@ public static void main(final String[] args) throws Exception { // Receive the sent message Message message1 = connection.receive(5, TimeUnit.SECONDS); - + String messagePayload = new String(message1.getPayload(), StandardCharsets.UTF_8); System.out.println("Received message: " + messagePayload); diff --git a/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/SimpleMQTTInterceptor.java b/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/SimpleMQTTInterceptor.java index 1b7b482e224..c705b81865e 100644 --- a/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/SimpleMQTTInterceptor.java +++ b/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/SimpleMQTTInterceptor.java @@ -51,8 +51,7 @@ public boolean intercept(final MqttMessage mqttMessage, RemotingConnection conne String modifiedMessage = "Modified message "; message.payload().setBytes(0, modifiedMessage.getBytes()); - } - else { + } else { if (mqttMessage instanceof MqttConnectMessage) { MqttConnectMessage connectMessage = (MqttConnectMessage) mqttMessage; System.out.println("A MQTT CONNECT control packet was intercepted " + connectMessage);