生产者 - 取消发布
1、取消发布(仅限特殊情况使用)
取消发布接口有两个参数,依次为:主题,跟踪Id。
MqMessage message = new MqMessage("hello");
//发布
client.publish("demo.topic", message);
//取消发布(只有同步方式)
client.unpublish("demo.topic", message.getTid());
取消发布接口有两个参数,依次为:主题,跟踪Id。
MqMessage message = new MqMessage("hello");
//发布
client.publish("demo.topic", message);
//取消发布(只有同步方式)
client.unpublish("demo.topic", message.getTid());