|
|
@@ -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); |
|
|
|