Tempus-947 Removed unused imports.

hashmapinc · Jan 16, 2019 · 23cf357 · 23cf357
1 parent 9e245ca
commit 23cf357
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 11 deletions.
diff --git a/transport/mqtt/src/main/java/com/hashmapinc/server/transport/mqtt/MqttTransportHandler.java b/transport/mqtt/src/main/java/com/hashmapinc/server/transport/mqtt/MqttTransportHandler.java
@@ -221,7 +221,7 @@ private void processDevicePublish(ChannelHandlerContext ctx, MqttPublishMessage
             } else if (topicName.equals(MqttTopics.DEVICE_ATTRIBUTES_TOPIC)) {
                 msg = adaptor.convertToActorMsg(deviceSessionCtx, MsgType.POST_ATTRIBUTES_REQUEST, mqttMsg);
             } else if (topicName.equals(MqttTopics.DEVICE_EVENT_TOPIC)) {
-                saveEventForDevice(mqttMsg);//adaptor.convertToActorMsg(deviceSessionCtx, MsgType.POST_DEVICE_EVENT, mqttMsg));
+                saveEventForDevice(mqttMsg);
             } else if (topicName.startsWith(MqttTopics.DEVICE_ATTRIBUTES_REQUEST_TOPIC_PREFIX)) {
                 msg = adaptor.convertToActorMsg(deviceSessionCtx, MsgType.GET_ATTRIBUTES_REQUEST, mqttMsg);
                 if (msgId >= 0) {

diff --git a/...ort/mqtt/src/main/java/com/hashmapinc/server/transport/mqtt/adaptors/JsonMqttAdaptor.java b/...ort/mqtt/src/main/java/com/hashmapinc/server/transport/mqtt/adaptors/JsonMqttAdaptor.java
@@ -17,7 +17,6 @@
 package com.hashmapinc.server.transport.mqtt.adaptors;
 
 import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonParser;
@@ -30,22 +29,16 @@
 import com.hashmapinc.server.common.transport.adaptor.AdaptorException;
 import com.hashmapinc.server.common.transport.adaptor.JsonConverter;
 import com.hashmapinc.server.transport.mqtt.MqttTopics;
+import com.hashmapinc.server.transport.mqtt.MqttTransportHandler;
 import com.hashmapinc.server.transport.mqtt.session.DeviceSessionCtx;
+import com.hashmapinc.server.transport.mqtt.sparkplug.SparkPlugEncodeService;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
 import io.netty.buffer.UnpooledByteBufAllocator;
-import io.netty.handler.codec.mqtt.MqttPublishMessage;
-import io.netty.handler.codec.mqtt.MqttMessage;
-import io.netty.handler.codec.mqtt.MqttFixedHeader;
-import io.netty.handler.codec.mqtt.MqttQoS;
-import io.netty.handler.codec.mqtt.MqttMessageType;
-import io.netty.handler.codec.mqtt.MqttPublishVariableHeader;
+import io.netty.handler.codec.mqtt.*;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
-import com.hashmapinc.server.transport.mqtt.MqttTransportHandler;
-import com.hashmapinc.server.transport.mqtt.sparkplug.SparkPlugEncodeService;
 
-import java.io.IOException;
 import java.nio.charset.Charset;
 import java.util.*;