@Test public void testOnewaySendOrderly() throws InterruptedException { for (int i = 0; i < 3; i++) { int id = 1024; producer.onewaySendOrderly(id); logger.info("[testOnewaySendOrderly][发送编号：[{}] 发送完成]", id); } new CountDownLatch(1).await(); }
public void onewaySendOrderly(Integer id) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.sendOneWayOrderly(Demo06Message.TOPIC, message, String.valueOf(id)); }
Demo06Producer { public void onewaySendOrderly(Integer id) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.sendOneWayOrderly(Demo06Message.TOPIC, message, String.valueOf(id)); } }
Demo06Producer { public void onewaySendOrderly(Integer id) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.sendOneWayOrderly(Demo06Message.TOPIC, message, String.valueOf(id)); }  }
Demo06Producer { public void onewaySendOrderly(Integer id) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.sendOneWayOrderly(Demo06Message.TOPIC, message, String.valueOf(id)); }  SendResult syncSendOrderly(Integer id); void asyncSendOrderly(Integer id, SendCallback callback); void onewaySendOrderly(Integer id); }
Demo06Producer { public void onewaySendOrderly(Integer id) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.sendOneWayOrderly(Demo06Message.TOPIC, message, String.valueOf(id)); }  SendResult syncSendOrderly(Integer id); void asyncSendOrderly(Integer id, SendCallback callback); void onewaySendOrderly(Integer id);  }