init

pump-web/src/main/java/com/tuoren/web/rabbit/RabbitHandle.java

@@ -14,17 +14,20 @@ import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.Channel;
+import com.tuoren.common.utils.ConstastUtils;
 import com.tuoren.web.layer.d0.PumpRemovePushRabbitDTO;
 import com.tuoren.web.layer.entity.*;
 import com.tuoren.web.layer.service.*;
 
 import com.tuoren.web.push.PushInfo;
+import com.tuoren.web.utils.DataUtils;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 import org.springframework.amqp.core.Exchange;
 import org.springframework.amqp.rabbit.annotation.Queue;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.rabbit.connection.CorrelationData;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
@@ -277,7 +280,7 @@ public class RabbitHandle {
 				.forEach((k,v)->{
 					v.stream()
 							.map(PumpRemovePushRabbitDTO::parse)
-							.forEach(pump-> rabbitTemplate.convertAndSend("removePump", k,JSONUtil.toJsonStr(pump)));
+							.forEach(pump-> rabbitTemplate.convertAndSend(ConstastUtils.ROUTING_KEY+k,JSONUtil.toJsonStr(v)));
 			;
 		});
 	}