延迟消息

MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("test msg");
//消息延迟60S
long time = 60 * 1000;
message.setLongProperty(ScheduledMessage.PMQ_SCHEDULED_DELAY, time);
producer.send(message);

客户端使用延迟消息必须遵守如下配置属性:

属性名称 类型 描述
PMQ_SCHEDULED_DELAY long 消息延迟时间单位:毫秒。
PMQ_SCHEDULED_PERIOD long 消息发送周期单位时间:毫秒。如 5秒一次 配置 PMQ_SCHEDULED_PERIOD = 5*1000。
PMQ_SCHEDULED_REPEAT int 消息重复发送次数。
PMQ_SCHEDULED_CRON string 使用Cron 表达式 设置定时发送。

results matching ""

    No results matching ""