@@ -35,8 +35,8 @@ public class IotMessageListener implements MessageListener { | |||||
@Override | @Override | ||||
public void run() { | public void run() { | ||||
// task to run goes here | // task to run goes here | ||||
count.getAndSet(0); | |||||
log.warn("约1分钟处理 {} 个请求",count); | log.warn("约1分钟处理 {} 个请求",count); | ||||
count.getAndSet(0); | |||||
//System.out.println("Hello, stranger"); | //System.out.println("Hello, stranger"); | ||||
} | } | ||||
}; | }; | ||||