Commit 9b57bde6 authored by terrfly's avatar terrfly
Browse files

ActiveMQSender 修改单位为:s

parent bafce062
...@@ -52,7 +52,7 @@ public class ActiveMQSender implements IMQSender { ...@@ -52,7 +52,7 @@ public class ActiveMQSender implements IMQSender {
public void send(AbstractMQ mqModel, int delay) { public void send(AbstractMQ mqModel, int delay) {
jmsTemplate.send(activeMQConfig.getDestination(mqModel), session -> { jmsTemplate.send(activeMQConfig.getDestination(mqModel), session -> {
TextMessage tm = session.createTextMessage(mqModel.toMessage()); TextMessage tm = session.createTextMessage(mqModel.toMessage());
tm.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay); tm.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay * 1000);
tm.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, 1*1000); tm.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, 1*1000);
tm.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, 1); tm.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, 1);
return tm; return tm;
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment