| | |
|---|
| | | nettyServerHandler.stringRedisTemplate.boundValueOps(serial).set(JSONObject.toJSONString(comPropertyEquipment)); |
|---|
| | | } |
|---|
| | | int finalDuration = duration; |
|---|
| | | nettyServerHandler.rabbitTemplate.convertAndSend("delayed.exchange", "delayed.key", comPropertyEquipment, message -> { |
|---|
| | | nettyServerHandler.rabbitTemplate.convertAndSend("huacheng.delayed.exchange", "huacheng.delayed.key", comPropertyEquipment, message -> { |
|---|
| | | message.getMessageProperties().setHeader("x-delay", finalDuration * 1000 * 3601); |
|---|
| | | return message; |
|---|
| | | }); |
|---|
