|
@@ -54,7 +54,7 @@ import java.util.concurrent.TimeUnit; |
|
@@ -54,7 +54,7 @@ import java.util.concurrent.TimeUnit; |
|
54
|
* 设备指令监听服务
|
54
|
* 设备指令监听服务
|
|
55
|
*/
|
55
|
*/
|
|
56
|
@Service
|
56
|
@Service
|
|
57
|
-@RocketMQMessageListener(consumerGroup = "deviceCommand", topic = "deviceCommandListen",selectorType = SelectorType.TAG,selectorExpression = "${rocketmq.operationToken}",messageModel = MessageModel.BROADCASTING)
|
57
|
+@RocketMQMessageListener(consumerGroup = "${rocketmq.consumerGroup}", topic = "${rocketmq.topic}",selectorType = SelectorType.TAG,selectorExpression = "${rocketmq.operationToken}",messageModel = MessageModel.BROADCASTING)
|
|
58
|
public class DeviceCommandListenService implements RocketMQReplyListener<MessageExt, Message>, RocketMQPushConsumerLifecycleListener {
|
58
|
public class DeviceCommandListenService implements RocketMQReplyListener<MessageExt, Message>, RocketMQPushConsumerLifecycleListener {
|
|
59
|
private static final Logger log = LoggerFactory.getLogger(DeviceCommandListenService.class);
|
59
|
private static final Logger log = LoggerFactory.getLogger(DeviceCommandListenService.class);
|
|
60
|
|
60
|
|
