延迟消息
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 表达式 设置定时发送。 |