Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA MQTT interceptor example checkstyle

This commit is contained in:
Justin Bertram 2017-08-21 09:41:48 -05:00 committed by Clebert Suconic
parent 8d3f484387
commit 3d89a5eb21
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/InterceptorExample.java
View File

@ -54,7 +54,7 @@ public class InterceptorExample {
// Receive the sent message // Receive the sent message
Message message1 = connection.receive(5, TimeUnit.SECONDS); Message message1 = connection.receive(5, TimeUnit.SECONDS);
String messagePayload = new String(message1.getPayload(), StandardCharsets.UTF_8); String messagePayload = new String(message1.getPayload(), StandardCharsets.UTF_8);
System.out.println("Received message: " + messagePayload); System.out.println("Received message: " + messagePayload);

3
examples/features/standard/interceptor-client-mqtt/src/main/java/org/apache/activemq/artemis/mqtt/example/SimpleMQTTInterceptor.java
View File

@ -51,8 +51,7 @@ public class SimpleMQTTInterceptor implements MQTTInterceptor {
String modifiedMessage = "Modified message "; String modifiedMessage = "Modified message ";
message.payload().setBytes(0, modifiedMessage.getBytes()); message.payload().setBytes(0, modifiedMessage.getBytes());
} } else {
else {
if (mqttMessage instanceof MqttConnectMessage) { if (mqttMessage instanceof MqttConnectMessage) {
MqttConnectMessage connectMessage = (MqttConnectMessage) mqttMessage; MqttConnectMessage connectMessage = (MqttConnectMessage) mqttMessage;
System.out.println("A MQTT CONNECT control packet was intercepted " + connectMessage); System.out.println("A MQTT CONNECT control packet was intercepted " + connectMessage);