|
@@ -29,6 +29,8 @@ public class MqConfig {
|
|
|
private String callbackTopic;
|
|
|
@Value("${pushMessage.callback.tag}")
|
|
|
private String callbackTag;
|
|
|
+ @Value("${pushMessage.callback.groupId}")
|
|
|
+ private String callbackGroupId;
|
|
|
|
|
|
@Resource
|
|
|
private MessageCallbackCustomer messageCallbackCustomer;
|
|
@@ -55,6 +57,7 @@ public class MqConfig {
|
|
|
//配置文件
|
|
|
Properties properties = getMqProperties();
|
|
|
properties.setProperty(PropertyKeyConst.ConsumeThreadNums, "20");
|
|
|
+ properties.setProperty(PropertyKeyConst.GROUP_ID, callbackGroupId);
|
|
|
consumerBean.setProperties(properties);
|
|
|
//订阅关系
|
|
|
Map<Subscription, MessageListener> subscriptionTable = new HashMap<>();
|