修改dcc消费者

This commit is contained in:
zren25
2025-03-31 17:55:42 +08:00
parent 8de0a69f36
commit b5595bc303

View File

@@ -27,8 +27,9 @@ import org.springframework.web.bind.annotation.RestController;
@RestController
@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopic}",
topic = "${rocketmq.consumer.corpus.dcctopicgroup}",
instanceName = "CorpusDccMqConsumer1",
enableMsgTrace = true)
public class CorpusDccMqProducer implements RocketMQListener<MessageExt> {
public class CorpusDccMqConsumer implements RocketMQListener<MessageExt> {
@Autowired
private TmTelephoneCorpusService tmTelephoneCorpusService;