@Test public void testSyncSendReturn() throws InterruptedException { int id = (int) (System.currentTimeMillis() / 1000); producer.syncSendReturn(id); logger.info("[testSyncSendReturn][发送编号：[{}] 发送成功]", id); new CountDownLatch(1).await(); }
public void syncSendReturn(Integer id) { Demo13Message message = new Demo13Message(); message.setId(id); rabbitTemplate.convertAndSend(Demo13Message.EXCHANGE, "error", message); }
Demo13Producer { public void syncSendReturn(Integer id) { Demo13Message message = new Demo13Message(); message.setId(id); rabbitTemplate.convertAndSend(Demo13Message.EXCHANGE, "error", message); } }
Demo13Producer { public void syncSendReturn(Integer id) { Demo13Message message = new Demo13Message(); message.setId(id); rabbitTemplate.convertAndSend(Demo13Message.EXCHANGE, "error", message); }  }
Demo13Producer { public void syncSendReturn(Integer id) { Demo13Message message = new Demo13Message(); message.setId(id); rabbitTemplate.convertAndSend(Demo13Message.EXCHANGE, "error", message); }  void syncSend(Integer id); void syncSendReturn(Integer id); }
Demo13Producer { public void syncSendReturn(Integer id) { Demo13Message message = new Demo13Message(); message.setId(id); rabbitTemplate.convertAndSend(Demo13Message.EXCHANGE, "error", message); }  void syncSend(Integer id); void syncSendReturn(Integer id);  }