Rocketmq遅延メッセージ消費
378 ワード
メッセージの消費時間は,インスタント消費,遅延消費,タイミング消費の3種類に分けられる(オープンソースなし)
メッセージ・オブジェクトの遅延時間を設定します.
遅延レベルを設定し、各レベルに対応する遅延時間を設定します.
遅延時間:1 s,5 s,10 s,30 s,1 m.....
遅延レベル:1,2,3,4
メッセージ・オブジェクトの遅延時間を設定します.
遅延レベルを設定し、各レベルに対応する遅延時間を設定します.
遅延時間: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);