Rocketmq遅延メッセージ消費

378 ワード

メッセージの消費時間は,インスタント消費,遅延消費,タイミング消費の3種類に分けられる(オープンソースなし)
メッセージ・オブジェクトの遅延時間を設定します.
遅延レベルを設定し、各レベルに対応する遅延時間を設定します.
遅延時間:1 s,5 s,10 s,30 s,1 m.....
遅延レベル:1,2,3,4
  Message message = new Message(JmsConfig.TOPIC,"taga" ,"6688" , ("hello xdclass rocketmq = "+text).getBytes() );
        message.setDelayTimeLevel(2);