|
@@ -280,7 +280,7 @@ public class RabbitHandle {
|
|
|
.forEach((k,v)->{
|
|
.forEach((k,v)->{
|
|
|
v.stream()
|
|
v.stream()
|
|
|
.map(PumpRemovePushRabbitDTO::parse)
|
|
.map(PumpRemovePushRabbitDTO::parse)
|
|
|
- .forEach(pump-> rabbitTemplate.convertAndSend(ConstastUtils.ROUTING_KEY+k,JSONUtil.toJsonStr(v)));
|
|
|
|
|
|
|
+ .forEach(pump-> rabbitTemplate.convertAndSend(ConstastUtils.ROUTING_KEY+k,JSONUtil.toJsonStr(pump)));
|
|
|
;
|
|
;
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
