类 ProducerUtils

java.lang.Object
com.cdkjframework.rocket.producer.ProducerUtils

@Component public class ProducerUtils extends Object
  • 构造器详细资料

    • ProducerUtils

      public ProducerUtils(com.aliyun.openservices.ons.api.bean.OrderProducerBean buildOrderProducer)
      构造函数
  • 方法详细资料

    • send

      public static String send(String topic, String tag, String body, String shardingKey) throws GlobalException
      发送消息
      参数:
      topic - 主题
      tag - tag
      body - 消息内容
      shardingKey - 设置代表消息的业务关键属性,请尽可能全局唯一。
      返回:
      返回结果
      抛出:
      GlobalException
    • send

      public static String send(String topic, String tag, String body, String shardingKey, Long startDeliverTime) throws GlobalException
      发送消息
      参数:
      topic - 主题
      tag - tag
      body - 消息内容
      shardingKey - 设置代表消息的业务关键属性,请尽可能全局唯一。
      startDeliverTime - 定时消息
      返回:
      返回结果
      抛出:
      GlobalException