|
...
|
...
|
@@ -7,6 +7,7 @@ import com.zhonglai.luhui.device.analysis.dto.Message; |
|
|
|
import com.zhonglai.luhui.device.analysis.dto.MessageCode;
|
|
|
|
import com.zhonglai.luhui.mqtt.comm.service.MqttDeviceService;
|
|
|
|
import org.apache.rocketmq.common.message.MessageExt;
|
|
|
|
import org.apache.rocketmq.spring.annotation.MessageModel;
|
|
|
|
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
|
|
|
import org.apache.rocketmq.spring.annotation.SelectorType;
|
|
|
|
import org.apache.rocketmq.spring.core.RocketMQReplyListener;
|
|
...
|
...
|
@@ -17,7 +18,7 @@ import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
|
|
|
|
@Service
|
|
|
|
@RocketMQMessageListener(consumerGroup = "deviceCommand", topic = "${rocketmq.send-topic:}",selectorType = SelectorType.TAG,selectorExpression = "${rocketmq.send-tag:}")
|
|
|
|
@RocketMQMessageListener(consumerGroup = "deviceCommand", topic = "${rocketmq.send-topic:}",selectorType = SelectorType.TAG,selectorExpression = "${rocketmq.send-tag:}",messageModel = MessageModel.BROADCASTING)
|
|
|
|
public class RocketMqService implements RocketMQReplyListener<MessageExt, Message> {
|
|
|
|
private static final Logger log = LoggerFactory.getLogger(RocketMqService.class);
|
|
|
|
|
...
|
...
|
|
