首页 > TAG信息列表 > spring-rabbit

java-Spring AMQP集成-用户手册确认

我正在测试具有Spring-Integration支持的Spring-AMQP,我已经进行了配置和测试： <rabbit:connection-factory id="connectionFactory" /> <rabbit:queue name="durableQ"/> <int:channel id="consumingChannel"> <int:queue capacity="

春季-向多个RabbitMQ使用者发送相同的消息

需求： 1)我需要通过Java应用程序并使用主题交换和存储来获取存储在Mongo DB中的数据.绑定键,在RabbitMQ上创建了3个队列.到目前为止,我已经执行了所有操作. 问题从第二点开始. 2)当消息应该对所有3个队列的多个使用者可用时.但是,当第一个使用者使用3个队列中的消息时,其余使用者将

java-用于RabbitMQ的Spring SimpleMessageListenerContainer在无效消息上中止

我正在使用springs SimpleMessageListenerContainer来使用RabbitMQ队列中的消息.一切正常,但是当无效消息发送到队列(例如无效的json)时,侦听器将中止,关闭工作进程并且不接受任何其他消息. 是否可以将其配置为丢弃中断的消息并继续监听其他消息？ 我正在使用sprint-rabbit-1.6.1.REL

春季-如何同时使用Rabbit连接缓存模式和自动声明功能？

Spring AMQP Reference说： Starting with version 1.3, the CachingConnectionFactory can be configured to cache connections as well as just channels. In this case, each call to createConnection() creates a new connection (or retrieves an idle one from the ca

春季-RabbitTemplate接收消息并重新排队

我的问题与此非常相似： RabbitTemplate receive and requeue不幸的是,尽管答案不符合我的需要,但已被标记为已回答. 我想模仿Rabbit Admin UI的功能,即我想从队列中同步读取消息,但又不想让队列丢失它们,即像偷看一样. RabbitTemplate receive and requeue的答案建议使用侦听器,但在

Spring amqp不向队列发布消息,而是向Exchange发布消息

我正在尝试测试& RabbitMQ的基准spring-amqp具有多个队列,因此我为每个队列创建了兔子模板并使用它来发送消息.发送的消息成功,我可以在交换机中看到一条消息,但我在队列中看不到任何内容.我猜这是非常小的设置,但无法弄明白. 这是我的applicationContext.xml <bean id="banchmark

如何在Spring启动应用程序中使用spring-rabbit处理JSON消息？

这是我的代码片段. > MQConfiguration类用于配置 @Configuration public class MQConfiguration { @Bean public Receiver receiver() { return new Receiver(); } } > Receiver类用于处理接收消息 @RabbitListener(queues = "testMQ") public class Receiv

Java / Spring – 从内部消费者发送RabbitMQ消息

从当前队列的使用者向另一个队列发送消息是否合法且安全？ public void onMessage(){ //save to db Order o=myservice.create(order); Object o=rabbitTemplate.convertSendAndReceive(queue2,orderId); } 我认为在这种情况下,第二个队列的使用者可能看不到保存的

java – Spring RabbitTemplate – 如何在发送时自动创建队列

我和Spring的RabbitTemplate一起使用RabbitMQ. 使用模板发送方法向队列发送消息时,如果队列尚未存在,我希望自动创建/声明队列. 这非常重要,因为根据我们的业务逻辑,队列名称是在运行时生成的,我不能提前声明它们. 以前我们使用JmsTemplate和任何调用发送或接收自动创建队列.解决方

java – Spring注释@Retryable – 如何设置拦截器

我在@Serviceclass中的方法上使用@Retryable注释 @Service @EnableRetry public class PushService { @Retryable(maxAttempts=5) public Result pushIt(myMessage messageIn) { ... } } 它就像一个魅力：我直接从RabbitMQ收到一条消息,直到没有错误或者尝试

java – Spring rabbitmq用动态绑定发送到交换

我尝试使用TopicExchange来屏蔽消息. 配置： <rabbit:connection-factory id="connectionFactory" host="localhost" username="guest" password="guest"/> <rabbit:template id="rabbitTemplate" connection-factory=&