|
@@ -20,7 +20,7 @@ import java.util.function.Function;
|
|
@Slf4j
|
|
@Slf4j
|
|
@Service
|
|
@Service
|
|
@AllArgsConstructor
|
|
@AllArgsConstructor
|
|
-@RocketMQMessageListener(topic = "${rocketmq.consumer.topic}", consumerGroup = "${rocketmq.consumer.group}")
|
|
|
|
|
|
+@RocketMQMessageListener(topic = "repeat-upload", consumerGroup = "common-group")
|
|
public class RocketMQConsumerService implements RocketMQListener<String> {
|
|
public class RocketMQConsumerService implements RocketMQListener<String> {
|
|
|
|
|
|
private final RepeatService repeatService;
|
|
private final RepeatService repeatService;
|