- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
有没有办法将 SimpleMessageListenerContainer
初始化为停止状态?
即我不想使用任何 JMS 消息,直到稍后用户执行启动 JMS 容器的操作
我尝试在创建 bean 后立即调用 .stop()
...但似乎还为时过早。
稍后调用停止/启动工作正常,但在用户准备好之前我不想冒险处理任何消息。
最佳答案
SimpleMessageListenerContainer
实现SmartLifecycle
界面。该接口(interface)定义了一个方法isAutoStartup
。当此方法返回true
时,组件将自动启动。
大多数实现 SmartLifecycle
接口(interface)的 bean 也有一个方法 setAutoStartup
来允许设置此属性。将其设置为 false
将禁用组件的自动启动。
<bean class="org.springframework.jms.listener.SimpleMessageListenerContainer">
<property name="autoStartup" value="false" />
// Other Properties initialization
</bean>
或者在Java配置中
@Bean
public SimpleMessageListenerContainer container() {
SimpleMessageListenerContainer smlc = new SimpleMessageListenerContainer();
smlc.setAutoStartup(false);
...
return smlc;
}
目前无法使用 jms 命名空间设置此属性。
关于java - 将 SimpleMessageListenerContainer 初始化为已停止,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24015906/
我可以理解org.springframework.util.backoff存在于简单的用例中并用于核心 spring 模块。 (与使用 spring-retry 相比)。 但我的问题是,为什么spri
当某个事件到达时,我使用 container.stop(); 停止我的 rabbitmq listner,并在所需的工作完成后,使用 重新启动它container.start(),但是当新事件到达时,
我有一个传入数据流作为单独的消息发送到 RabbitMQ。 我想将这些发送到需要一批消息的服务。当我有一批 1000 条消息或 5 秒过期时,我需要将请求发送到服务。使用 SimpleMessageL
在任何可能的错误(缺少队列、连接问题等)上关闭 SimpleMessageListenerContainer(以编程方式创建,而不是作为 bean)并创建新的(在运行时重新声明所有绑定(bind))的
我尝试使用 spring boot 连接到 RabbitMQ。连接应始终重新启动/重试连接。我在发生致命异常后重新连接时遇到问题。应用程序永远不会断开连接,也不会无限期地重试连接。 @Bean
我正在尝试在 spring amqp 中实现恢复。我已经使用下面的代码来实现相同的 RetryOperationsInterceptor retryInterceptorBuilder =RetryI
我正在使用 SimpleMessageListenerContainer作为通过 AMQP 进行远程处理的基础。只要在进程启动时可以访问 RabbitMQ 代理,一切都会顺利进行。但是,如果由于任何原
我有 2 个正在收听的 RabbitMQ 队列。对于 1 个队列,我需要一个消费者来确保一次只处理一条消息。 第二个队列可以在一秒钟内接收大量消息,我需要能够一次使用很多消息。 我有以下代码,它确实按
我正在使用 Java boot 1.4.0 和“spring-boot-starter-amqp”来连接到rabbitMq。消息生产者、消费者和rabbitMq服务器都在我的控制之下。在生产环境中的几
有没有办法将 SimpleMessageListenerContainer 初始化为停止状态? 即我不想使用任何 JMS 消息,直到稍后用户执行启动 JMS 容器的操作 我尝试在创建 bean 后立即
从 this question 开始,我们有一个 Rabbit 凭证失效的场景,我们需要在我们的 CachingConnectionFactory 上调用 resetConnection() 来获取一
我试图更好地了解如何在我的应用程序中实现构造函数注入(inject)。我有一些由 SimpleMessageListenerContainer 工作人员执行的后台进程,这些进程从 AMQP 服务器中提
我在 springrabbitmq 消费者端不断收到以下警告。它一直在寻找重新启动。 [SimpleAsyncTaskExecutor-3317] WARN org.springframework.
我正在使用 Spring Cloud 库来轮询 SQS。如何设置轮询间隔? @Bean @Primary public AmazonSQSAsync amazonSQSAsync() { re
最近我们遇到了一种情况,消息被消费者从队列中取出,但没有到达与该队列绑定(bind)的监听器。我们之所以能够做出这个断言,是因为我们的监听器上有一个拦截器(打印日志消息),该拦截器不会为这些消息触发。
我有一个 SimpleMessageListenerContainer,正在与 RabbitMQ 和 Java 一起使用。在大多数情况下,我没有遇到任何问题,但是在某些情况下,当消息发送到队列时,似乎
我们一直在使用一个框架来使用Spring AMQP,其中框架设置了SimpleMessageListenerContainer.setDefaultRequeueRejected(false), 这意
RabbitMQ 提供了选择性设置预取计数的功能。 使用 spring-amqp 的 SimpleMessageListenerContainer,我注意到预取计数始终被设置。我无法将预取计数设置为
我正在使用 springs SimpleMessageListenerContainer 来消费来自 RabbitMQ 队列的消息。一切正常,但是当向队列发送无效消息(例如无效的 json)时,监听器
我目前正在学习一些有关 RabbitMQ + SpringAMQ 的知识,我试图使我的 SimpleMessageListenerContainer 能够读取传递到我的两个队列的消息,但只有一个正在接
我是一名优秀的程序员,十分优秀!