|
|
@@ -17,7 +17,7 @@ import org.springframework.stereotype.Service;
|
|
|
messageModel = MessageModel.BROADCASTING,
|
|
|
consumerGroup = "${general.broadcast-event-group}",
|
|
|
topic = "${general.broadcast-event-topic}",
|
|
|
- consumeMode = ConsumeMode.ORDERLY)
|
|
|
+ consumeMode = ConsumeMode.CONCURRENTLY)
|
|
|
public class BroadcastEventListener implements RocketMQListener<JSONObject> {
|
|
|
|
|
|
@Override
|