|
|
@ -4,13 +4,11 @@ import com.mashibing.common.constant.RabbitMQConstant;
|
|
|
|
import com.mashibing.common.pojo.StandardReport;
|
|
|
|
import com.mashibing.common.pojo.StandardReport;
|
|
|
|
import com.mashibing.common.utils.JsonUtil;
|
|
|
|
import com.mashibing.common.utils.JsonUtil;
|
|
|
|
import com.mashibing.push.config.RabbitMQConfig;
|
|
|
|
import com.mashibing.push.config.RabbitMQConfig;
|
|
|
|
import com.mashibing.push.feignclient.Cacheclient;
|
|
|
|
import com.mashibing.push.feignclient.CacheClient;
|
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
import org.springframework.amqp.AmqpException;
|
|
|
|
|
|
|
|
import org.springframework.amqp.core.Message;
|
|
|
|
import org.springframework.amqp.core.Message;
|
|
|
|
import org.springframework.amqp.core.MessagePostProcessor;
|
|
|
|
|
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
|
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
@ -39,7 +37,7 @@ public class PushReportListener {
|
|
|
|
RestTemplate restTemplate;
|
|
|
|
RestTemplate restTemplate;
|
|
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
@Autowired
|
|
|
|
Cacheclient cacheclient;
|
|
|
|
CacheClient cacheclient;
|
|
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
@Autowired
|
|
|
|
RabbitTemplate rabbitTemplate;
|
|
|
|
RabbitTemplate rabbitTemplate;
|
|
|
|