在使用Spring RabbitMQ时，我从AMQP内部获得了ClassCastException。我们在生产环境中的应用程序日志中发现了这一点，无法重现这一点，但这对我们来说是一个真正的痛苦。基本上，一旦发生这种情况，整个堆栈似乎都会失败，因为然后我们会看到在该通道上发送无效的DeliveryTag，这会导致RabbitMQ关闭该通道。我们使用的是AMQPClient 5.4.3和SpringRabbit 2.1.2，RabbitMQ缓存模式是连接(
浏览 112提问于2019-10-11得票数 1
我正在尝试理解Spring配置。到目前为止，我从未遇到过一个侦听器正在监听(订阅)多个队列的xml配置。像wise一样，我从未发现有两个侦听器在同一个xml文件中订阅相同队列的代码。"/>
<bean id="messageListener" class="com.ndpar.spring.rabbitmq.MessageHandler“队列”属
浏览 0提问于2018-03-05得票数 1
回答已采纳
我正在创建一个用于侦听MessageListenerAdapter消息队列的Spring。connectionFactory, container.setQueueNames("queueA", "queueB");
container.set
浏览 1提问于2020-04-23得票数 0
回答已采纳
1回答
当RabbitMQ在RabbitMQ文件中配置时，我正在尝试理解Spring代码。在接收方xml文件中，我有
<rabbit:queue id="springQueue" name="spring.queue" auto-delete="true" durable="false"/>listener-container connection-facto
浏览 23提问于2018-02-27得票数 0
回答已采纳
我使用Spring来处理RabbitMQ中的消息。
</rabbit:listener-container>
<e
浏览 1提问于2017-04-18得票数 2
回答已采纳
1回答
我有两个单独的Java应用程序，我需要使用spring- RabbitMQ在这两个应用程序之间发送消息。在作为生产者的应用程序中，我使用JsonMessageConverter作为RabbitTemplate的消息转换器，以便在将其发送到队列之前将其转换为JSON消息。在另一个应用程序中，我希望将JSON消息转换回Java对象。我尝试过将SimpleMessageListenerContainer与自定义MessageListener一起使用，我可以从队列中</
浏览 3提问于2013-06-19得票数 0
回答已采纳
我正在尝试使用spring amqp来使用rabbitmq，下面是我的配置。<rabbit:connection-factory id="rabbitConnectionFactory"这是一个简单的消息监听器类，import org.springframework.
浏览 2提问于2014-04-21得票数 1
回答已采纳
我使用Spring在Java中使用RabbitMQ。我使用主题交换发送消息。此外，Spring有一个MessageListener接口，我只能使用它侦听命名队列。有没有一种方法可以使用MessageListener来使用来自自动声明队列的消息？
谢谢!
浏览 0提问于2014-07-08得票数 1
回答已采纳
我想写一个代码使用Spring AMQP将发送通知消息到APN。我随身带着.p12、认证和.pem文件。谁能帮我写代码使用Spring AMQP，它将发送通知消息。
提前谢谢。
浏览 3提问于2013-09-06得票数 0
使用Spring在使用RabbitMQ时得到库存。factory.setNetworkRecoveryInterval(10000);
使用<e
浏览 8提问于2014-08-07得票数 4
回答已采纳
3回答
我有一个远程RabbitMQ服务器，它有一些我想要侦听的队列。我看到了这条线在一本教程里。#{queueName.name}是什么意思？org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations(BlockingQueueConsumer.java:711) ~[spring-rabbitorg.
浏览 1提问于2018-08-30得票数 2
回答已采纳
给定一个使用RabbitMQ队列中的消息的基本MessageListener实现，如何根据处理消息时可能抛出的异常类型将消息发送到不同的死信队列？最初发布消息的队列上设置了x-dead-letter-exchange和x-dead-letter-routing-key，但在我的示例中这是不够的。如果重要的话，我的应用程序使用的是Spring4和Spring Amqp。
浏览 1提问于2014-04-07得票数 0
我有一个使用Hibernate和PostgreSQL的Spring应用程序。它还使用Spring AMQP (RabbitMQ)。="transactionManager")private MyListener messageListenercontainer.setQueueNames("myQueue");
final MessageListenerAd
浏览 0提问于2012-06-28得票数 5
我试图在我的web应用程序的服务器启动时使用Spring在RabbitMQ中创建一个新的队列。我没有得到确切的配置代码如何实现它。下面是我的代码片段。请更正以下内容。container.setMessageListener(exampleListener()); }
public MessageListenerexampleListener() {
浏览 3提问于2016-07-27得票数 0
回答已采纳
我正在使用spring，在entry类的主要函数中，我定义了以下将启动应用程序的函数。c1 = new ClassPathXmlApplicationContext("rabbit-listener-context.xml");}
该兔子侦听器-context.xml定义了rabbitmq信息，然后我定义了以下内容以在rabbitmq中使用该消息。public class TutorialListener implements MessageLi
浏览 0提问于2014-11-18得票数 0
回答已采纳
2回答
我有一个要求，在一定的持续时间后发送消息到MessageListener，所以有任何方法来实现使用Spring。
例如。生产者产生消息并将消息发送到RabbitMQ q，消息接收侦听器立即收听该q，我想延迟在客户端接收该消息，比如在某些配置参数(例如1000 to )之后。
浏览 4提问于2016-11-16得票数 3
回答已采纳
我一直在遵循指南，通过Spring设置rabbitMQ通信。队列、交换、绑定是在应用程序启动时声明和初始化的。}
SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerSPRINGQUEUE); return container;
浏览 6提问于2022-06-24得票数 0
我在一个基于Spring RabbitMQ的应用程序的消费者端有以下代码： } }
当我将break放在try中的第一行时如何确保onMessage中的所有代码都被执行？(AMQChannel.java:144
浏览 2提问于2018-01-05得票数 0
通过实现RabbitMQ接口和设置SimpleMessageListenerContainer，我编写了一个SimpleMessageListenerContainer使用者。现在，我想编写一个集成测试：
在消息被我的MessageListener实现使用时等待。但是，由于我的MessageListener运行在一个单独的线程中，所以很难进行单元测试。在我的测试中使用Thread.sleep等待Mes
浏览 6提问于2015-01-22得票数 7
回答已采纳
1回答
使用DefaultMessageListenerContainer接收消息我使用属性"session = true“通过本地事务实现上述场景。Spring配置如下。<bean id="rmqConnectionFactory" class="com.rabbitmq.jms.admin.RMQ
浏览 5提问于2017-03-22得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
