|
|
@@ -13,8 +13,8 @@ import org.springframework.stereotype.Service;
|
|
|
@Slf4j
|
|
|
@AllArgsConstructor
|
|
|
@RocketMQMessageListener(
|
|
|
- consumerGroup = "${general.create-order-group}",
|
|
|
- topic = "${general.create-order-topic}",
|
|
|
+ consumerGroup = "${general.order-notify-group}",
|
|
|
+ topic = "${general.order-notify-topic}",
|
|
|
consumeMode = ConsumeMode.CONCURRENTLY)
|
|
|
public class OrderNotifyListener implements RocketMQListener<OrderNotifyEvent> {
|
|
|
private OrderService orderService;
|