activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [4/4] activemq-artemis git commit: NO-JIRA MQTT interceptor example checkstyle
Date Wed, 23 Aug 2017 02:08:25 GMT
NO-JIRA MQTT interceptor example checkstyle


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/3d89a5eb
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3d89a5eb
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3d89a5eb

Branch: refs/heads/master
Commit: 3d89a5eb2138c7496332725b43c3f72acf60d09a
Parents: 8d3f484
Author: Justin Bertram <jbertram@apache.org>
Authored: Mon Aug 21 09:41:48 2017 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Tue Aug 22 22:08:24 2017 -0400

----------------------------------------------------------------------
 .../apache/activemq/artemis/mqtt/example/InterceptorExample.java  | 2 +-
 .../activemq/artemis/mqtt/example/SimpleMQTTInterceptor.java      | 3 +--
 2 files changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3d89a5eb/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/InterceptorExample.java
----------------------------------------------------------------------
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 4fb5abf..e72c93f 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 class InterceptorExample {
 
       // 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);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3d89a5eb/examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/SimpleMQTTInterceptor.java
----------------------------------------------------------------------
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 1b7b482..c705b81 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 class SimpleMQTTInterceptor implements MQTTInterceptor {
          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);


Mime
View raw message