@Test public void testASyncSendOrderly() throws InterruptedException { for (int i = 0; i < 3; i++) { int id = 1024; producer.asyncSendOrderly(id, new SendCallback() { @Override public void onSuccess(SendResult result) { logger.info("[testASyncSendOrderly][发送编号：[{}] 发送成功，结果为：[{}]]", id, result); } @Override public void onException(Throwable e) { logger.info("[testASyncSendOrderly][发送编号：[{}] 发送异常]]", id, e); } }); } new CountDownLatch(1).await(); }
public void asyncSendOrderly(Integer id, SendCallback callback) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.asyncSendOrderly(Demo06Message.TOPIC, message, String.valueOf(id), callback); }
Demo06Producer { public void asyncSendOrderly(Integer id, SendCallback callback) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.asyncSendOrderly(Demo06Message.TOPIC, message, String.valueOf(id), callback); } }
Demo06Producer { public void asyncSendOrderly(Integer id, SendCallback callback) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.asyncSendOrderly(Demo06Message.TOPIC, message, String.valueOf(id), callback); }  }
Demo06Producer { public void asyncSendOrderly(Integer id, SendCallback callback) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.asyncSendOrderly(Demo06Message.TOPIC, message, String.valueOf(id), callback); }  SendResult syncSendOrderly(Integer id); void asyncSendOrderly(Integer id, SendCallback callback); void onewaySendOrderly(Integer id); }
Demo06Producer { public void asyncSendOrderly(Integer id, SendCallback callback) { Demo06Message message = new Demo06Message(); message.setId(id); rocketMQTemplate.asyncSendOrderly(Demo06Message.TOPIC, message, String.valueOf(id), callback); }  SendResult syncSendOrderly(Integer id); void asyncSendOrderly(Integer id, SendCallback callback); void onewaySendOrderly(Integer id);  }