@Test public void testOnewaySend() throws InterruptedException { int id = (int) (System.currentTimeMillis() / 1000); producer.onewaySend(id); logger.info("[testOnewaySend][发送编号：[{}] 发送完成]", id); new CountDownLatch(1).await(); }
public void onewaySend(Integer id) { Demo01Message message = new Demo01Message(); message.setId(id); rocketMQTemplate.sendOneWay(Demo01Message.TOPIC, message); }
Demo01Producer { public void onewaySend(Integer id) { Demo01Message message = new Demo01Message(); message.setId(id); rocketMQTemplate.sendOneWay(Demo01Message.TOPIC, message); } }
Demo01Producer { public void onewaySend(Integer id) { Demo01Message message = new Demo01Message(); message.setId(id); rocketMQTemplate.sendOneWay(Demo01Message.TOPIC, message); }  }
Demo01Producer { public void onewaySend(Integer id) { Demo01Message message = new Demo01Message(); message.setId(id); rocketMQTemplate.sendOneWay(Demo01Message.TOPIC, message); }  SendResult syncSend(Integer id); void asyncSend(Integer id, SendCallback callback); void onewaySend(Integer id); }
Demo01Producer { public void onewaySend(Integer id) { Demo01Message message = new Demo01Message(); message.setId(id); rocketMQTemplate.sendOneWay(Demo01Message.TOPIC, message); }  SendResult syncSend(Integer id); void asyncSend(Integer id, SendCallback callback); void onewaySend(Integer id);  }