Commit e7382e31 authored by terrfly's avatar terrfly
Browse files

仅接收MQ消息对象无需集成ActiveMQTopic

parent 1070ffea
...@@ -18,7 +18,6 @@ package com.jeequan.jeepay.pay.mq.topic; ...@@ -18,7 +18,6 @@ package com.jeequan.jeepay.pay.mq.topic;
import com.jeequan.jeepay.core.constants.CS; import com.jeequan.jeepay.core.constants.CS;
import com.jeequan.jeepay.pay.service.ConfigContextService; import com.jeequan.jeepay.pay.service.ConfigContextService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
...@@ -32,14 +31,10 @@ import org.springframework.stereotype.Component; ...@@ -32,14 +31,10 @@ import org.springframework.stereotype.Component;
*/ */
@Slf4j @Slf4j
@Component @Component
public class MqTopic4ModifyIsvInfo extends ActiveMQTopic{ public class MqTopic4ModifyIsvInfo{
@Autowired private ConfigContextService configContextService; @Autowired private ConfigContextService configContextService;
public MqTopic4ModifyIsvInfo(){
super(CS.MQ.TOPIC_MODIFY_ISV_INFO);
}
/** 接收 更新系统配置项的消息 **/ /** 接收 更新系统配置项的消息 **/
@JmsListener(destination = CS.MQ.TOPIC_MODIFY_ISV_INFO, containerFactory = "jmsListenerContainer") @JmsListener(destination = CS.MQ.TOPIC_MODIFY_ISV_INFO, containerFactory = "jmsListenerContainer")
public void receive(String isvNo) { public void receive(String isvNo) {
......
...@@ -19,7 +19,6 @@ import com.alibaba.fastjson.JSONObject; ...@@ -19,7 +19,6 @@ import com.alibaba.fastjson.JSONObject;
import com.jeequan.jeepay.core.constants.CS; import com.jeequan.jeepay.core.constants.CS;
import com.jeequan.jeepay.pay.service.ConfigContextService; import com.jeequan.jeepay.pay.service.ConfigContextService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
...@@ -33,14 +32,10 @@ import org.springframework.stereotype.Component; ...@@ -33,14 +32,10 @@ import org.springframework.stereotype.Component;
*/ */
@Slf4j @Slf4j
@Component @Component
public class MqTopic4ModifyMchInfo extends ActiveMQTopic{ public class MqTopic4ModifyMchInfo{
@Autowired private ConfigContextService configContextService; @Autowired private ConfigContextService configContextService;
public MqTopic4ModifyMchInfo(){
super(CS.MQ.TOPIC_MODIFY_MCH_INFO);
}
/** 接收 [商户配置信息] 的消息 /** 接收 [商户配置信息] 的消息
* 已知推送节点: * 已知推送节点:
* 1. 更新商户基本资料和状态 * 1. 更新商户基本资料和状态
......
...@@ -18,28 +18,23 @@ package com.jeequan.jeepay.pay.mq.topic; ...@@ -18,28 +18,23 @@ package com.jeequan.jeepay.pay.mq.topic;
import com.jeequan.jeepay.core.constants.CS; import com.jeequan.jeepay.core.constants.CS;
import com.jeequan.jeepay.service.impl.SysConfigService; import com.jeequan.jeepay.service.impl.SysConfigService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/* /*
* 更改系统配置参数 * 更改系统配置参数
* *
* @author terrfly * @author terrfly
* @site https://www.jeepay.vip * @site https://www.jeepay.vip
* @date 2021/6/8 17:35 * @date 2021/6/8 17:35
*/ */
@Slf4j @Slf4j
@Component @Component
public class MqTopic4ModifySysConfig extends ActiveMQTopic{ public class MqTopic4ModifySysConfig{
@Autowired private SysConfigService sysConfigService; @Autowired private SysConfigService sysConfigService;
public MqTopic4ModifySysConfig(){
super(CS.MQ.TOPIC_MODIFY_SYS_CONFIG);
}
/** 接收 更新系统配置项的消息 **/ /** 接收 更新系统配置项的消息 **/
@JmsListener(destination = CS.MQ.TOPIC_MODIFY_SYS_CONFIG, containerFactory = "jmsListenerContainer") @JmsListener(destination = CS.MQ.TOPIC_MODIFY_SYS_CONFIG, containerFactory = "jmsListenerContainer")
public void receive(String msg) { public void receive(String msg) {
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment