代码之家 › 专栏 › 技术社区 › Smoothi

设置Spring集成中消息的生存时间

qpid messaging spring-integration jms spring

Smoothi · 技术社区 · 10 年前

我需要设定一个时间来实现我的信息。

我尝试了以下示例,但生存时间将被忽略/

上下文.xml

<int:channel id="publishChannel"/>

<int-jms:outbound-channel-adapter 
         channel="publishChannel" 
         destination="defaultDestination"
         time-to-live="5000" 
         pub-sub-domain="false" />

出版商

import org.springframework.integration.annotation.Publisher;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;

@Service("publishService")
public class PublishService{
    private MessageChannel messageChannel;

    @Publisher(channel = "publishChannel")
    public Message<?> sendMessage (Message<?> message) {
        return message;
    }
}

我希望有人能帮助我!:)

1 回复 | 直到 10 年前

Artem Bilan 10 年前

相符合的 JmsTemplate 我们有JavaDocs:

/**
 * Set the time-to-live of the message when sending.
 * <p>Since a default value may be defined administratively,
 * this is only used when "isExplicitQosEnabled" equals "true".
 * @param timeToLive the message's lifetime (in milliseconds)
 * @see #isExplicitQosEnabled
 * @see javax.jms.Message#DEFAULT_TIME_TO_LIVE
 * @see javax.jms.MessageProducer#send(javax.jms.Message, int, int, long)
 */
public void setTimeToLive(long timeToLive) {
    this.timeToLive = timeToLive;
}

所以,如果 explicitQosEnabled 不是 true ( JmsTemplate#doSend ):

if (isExplicitQosEnabled()) {
    producer.send(message, getDeliveryMode(), getPriority(), getTimeToLive());
}

因此,您应该添加 explicit-qos-enabled="true" 与…并列 time-to-live="5000" 为您的 <int-jms:outbound-channel-adapter> .

推荐文章

user1610362 · Azure ServiceBus JMS库是否支持托管身份?

2 年前

MI-Merc · 远程代理故障切换后,Wildfly JMS消息发送失败

2 年前

trougc · Nifi:如何在PublishJMS中将消息格式从MQHRF2更改为MQSTR?

6 年前

ÐÐ¸ÐºÐ¸ÑÐ° ÐÐ¸ÑÐ°Ð¹Ð»Ð¾Ð² · 消息驱动bean不接收来自主题的消息

6 年前

Ankit Singodia · 如何使用RabbitMQ处理应用程序崩溃

6 年前

Beto Neto · ActiveMQ,丢弃未使用的消息

6 年前

mohamnag · junit或spock的JMS测试工具

6 年前

jaletechs · 作业或任务调度

6 年前

M06H · Java语言lang.NoClassDefFoundError发送到oracle aq时出错

6 年前

Ryan Pelletier · ActiveMQ SSL连接密钥库和信任库类型

7 年前