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