From df34c7fcccd8264cb3f6260f6b8f8e4b885ef4c9 Mon Sep 17 00:00:00 2001 From: linwl <304115325@qq.com> Date: Thu, 25 Feb 2021 09:29:53 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=B0=83=E8=AF=95=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/telpo/iotgateway/listener/IotMessageListener.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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);