|
|
@@ -1,24 +1,14 @@
|
|
|
package com.zswl.dataservice.service.artemis;
|
|
|
|
|
|
import cn.hutool.json.JSONObject;
|
|
|
-import cn.hutool.json.JSONUtil;
|
|
|
-import com.zswl.dataservice.domain.mqtt.OperationMessage;
|
|
|
-import com.zswl.dataservice.httpRequest.ApiRequestService;
|
|
|
import com.zswl.dataservice.model.mqtt.SendMessageModel;
|
|
|
-import com.zswl.dataservice.service.base.RedisService;
|
|
|
import com.zswl.dataservice.service.base.SuperService;
|
|
|
-import com.zswl.dataservice.service.payment.HxzService;
|
|
|
-import com.zswl.dataservice.type.OperationType;
|
|
|
import com.zswl.dataservice.utils.DateUtils;
|
|
|
import com.zswl.dataservice.utils.mqtt.mqttConfig.client.MQClient;
|
|
|
import com.zswl.dataservice.utils.mqtt.mqttConfig.constant.MQConstant;
|
|
|
import com.zswl.dataservice.utils.result.ResultContent;
|
|
|
import jakarta.jms.Message;
|
|
|
-import jakarta.jms.TextMessage;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
-import org.apache.activemq.artemis.jms.client.ActiveMQBytesMessage;
|
|
|
-import org.apache.activemq.artemis.jms.client.ActiveMQTopic;
|
|
|
-import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.jms.annotation.JmsListener;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
@@ -33,21 +23,12 @@ import java.util.UUID;
|
|
|
@Service
|
|
|
public class ArtemisService extends SuperService {
|
|
|
|
|
|
- @Autowired
|
|
|
- RedisService redisService;
|
|
|
-
|
|
|
@Autowired
|
|
|
MQClient mqClient;
|
|
|
|
|
|
- @Autowired
|
|
|
- ApiRequestService apiRequestService;
|
|
|
-
|
|
|
@Autowired
|
|
|
OperationMessageService operationMessageService;
|
|
|
|
|
|
- @Autowired
|
|
|
- HxzService hxzService;
|
|
|
-
|
|
|
// 网关来的消息
|
|
|
@JmsListener(destination = "/v1/gateway/#", containerFactory = MQConstant.TopicListenerContainerFactory)
|
|
|
@JmsListener(destination = ".v1.gateway.#", containerFactory = MQConstant.TopicListenerContainerFactory)
|
