TIBCO-EMS: 根据JMS消息设置消息延迟header
TIBCO-EMS: Set message delay based on JMS message header
我需要根据特殊情况对不同的消息进行不同的延迟。有没有办法像在 ActiveMQ 中一样使用 TIBCO EMS 在消息中设置传递延迟 header?
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("test msg");
if (condition) {
long time = 60 * 1000;
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, time);
}
producer.send(message);
如果 Tibco EMS 支持 JMS 2,那么您可以使用 javax.jms.MessageProducer#setDeliveryDelay(long)
:
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("test msg");
if (condition) {
long time = 60 * 1000;
producer.setDeliveryDelay(time);
}
producer.send(message);
我需要根据特殊情况对不同的消息进行不同的延迟。有没有办法像在 ActiveMQ 中一样使用 TIBCO EMS 在消息中设置传递延迟 header?
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("test msg");
if (condition) {
long time = 60 * 1000;
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, time);
}
producer.send(message);
如果 Tibco EMS 支持 JMS 2,那么您可以使用 javax.jms.MessageProducer#setDeliveryDelay(long)
:
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("test msg");
if (condition) {
long time = 60 * 1000;
producer.setDeliveryDelay(time);
}
producer.send(message);