sonar
This commit is contained in:
@@ -27,7 +27,7 @@ import org.springframework.web.bind.annotation.RestController;
|
||||
@RestController
|
||||
@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopic}",
|
||||
topic = "${rocketmq.consumer.corpus.dcctopicgroup}",
|
||||
consumeThreadNumber=5)
|
||||
enableMsgTrace = true)
|
||||
public class CorpusDccMqProducer implements RocketMQListener<MessageExt> {
|
||||
|
||||
@Autowired
|
||||
|
||||
Reference in New Issue
Block a user