24 Ağustos 2020 Pazartesi

ActiveMQ activemq.xml Dosyası

schedulerSupport Alanı
Açıklaması şöyle
By default scheduled message support is disabled. We must enabled it in the broker XML configuration file.
Örnek
Şöyle yaparız
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost"
   dataDirectory="${activemq.data}" schedulerSupport="true">
Mesaja şöyle yaparız
message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, scheduledDelay);
Şöyle yaparız
public void send(Object object) {

  jmsTemplate.convertAndSend(QUEUE_NAME, object, m -> {
    m.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 10000);
    return m;
  });
}

Hiç yorum yok:

Yorum Gönder