diff --git a/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java b/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java index b0ddc6e..10633a7 100644 --- a/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java +++ b/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java @@ -19,7 +19,7 @@ import java.util.concurrent.ExecutorService; @Component public class IotMessageListener implements MessageListener { - private static int count = 0; + private int count = 0; private ExecutorService executorService; public void setExecutorService(ExecutorService executorService) { @@ -44,7 +44,7 @@ public class IotMessageListener implements MessageListener { /** * 在这里处理您收到消息后的具体业务逻辑。 */ - private static void processMessage(Message message) { + private void processMessage(Message message) { try { byte[] body = message.getBody(byte[].class); String content = new String(body);