1. 打开 ins的rocket
This commit is contained in:
parent
3d53e2fed4
commit
3f82ff3ff1
|
|
@ -33,7 +33,7 @@ import java.util.Objects;
|
||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@Component
|
@Component
|
||||||
//@RocketMQMessageListener(topic = ServiceConstant.INSPECTION + 1, consumerGroup = ServiceConstant.INSPECTION_CONSUMER_GROUP)
|
@RocketMQMessageListener(topic = ServiceConstant.INSPECTION + 1, consumerGroup = ServiceConstant.INSPECTION_CONSUMER_GROUP)
|
||||||
public class InspectionConsumerService implements RocketMQListener<TaskInfo> {
|
public class InspectionConsumerService implements RocketMQListener<TaskInfo> {
|
||||||
@Resource
|
@Resource
|
||||||
RemoteTaskService remoteTaskService;
|
RemoteTaskService remoteTaskService;
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue