使用SpringJMS设置每个消息的过期时间

Question

我通过SpringJMS在我的项目中使用MQ，作为代理我使用ActiveMQ。我需要基于消息设置过期，所以我尝试使用message.setjmsExpersion，但没有成功。所有到达ActiveMQ的消息都具有expiration=0。

有人成功地使用Spring为每个消息设置过期吗？

        long expiration = 0L;
        if (!producer.getDisableMessageTimestamp()) {
            long timeStamp = System.currentTimeMillis();
            message.setJMSTimestamp(timeStamp);
            if (timeToLive > 0) {
                expiration = timeToLive + timeStamp;
            }
        }
        message.setJMSExpiration(expiration);  
        //me: timeToLive coming from default values of Producer/JmsTemplate...

Answer 1

我不知道为什么Spring决定排除这一点，但是您可以扩展JmsTemplate并重载一些方法，传递一个timeToLive参数。

public class MyJmsTemplate extends JmsTemplate {

    public void send(final Destination destination,
            final MessageCreator messageCreator, final long timeToLive)
            throws JmsException {
        execute(new SessionCallback<Object>() {
            public Object doInJms(Session session) throws JMSException {
                doSend(session, destination, messageCreator, timeToLive);
                return null;
            }
        }, false);
    }

    protected void doSend(Session session, Destination destination,
            MessageCreator messageCreator, long timeToLive) throws JMSException {

        Assert.notNull(messageCreator, "MessageCreator must not be null");
        MessageProducer producer = createProducer(session, destination);
        try {
            Message message = messageCreator.createMessage(session);
            if (logger.isDebugEnabled()) {
                logger.debug("Sending created message: " + message);
            }
            doSend(producer, message, timeToLive);
            // Check commit - avoid commit call within a JTA transaction.
            if (session.getTransacted() && isSessionLocallyTransacted(session)) {
                // Transacted session created by this template -> commit.
                JmsUtils.commitIfNecessary(session);
            }
        } finally {
            JmsUtils.closeMessageProducer(producer);
        }
    }

    protected void doSend(MessageProducer producer, Message message,
            long timeToLive) throws JMSException {
        if (isExplicitQosEnabled() && timeToLive > 0) {
            producer.send(message, getDeliveryMode(), getPriority(), timeToLive);
        } else {
            producer.send(message);
        }
    }

}