我使用的是RabbitMQ Server2.3.1。
在一个通道中有5-6个队列。
该队列由java bean组成。
并且有相同数量的scala参与者聚集在特定的队列中。所有这些参与者都试图通过处理rabbitmq连接和通道的公共队列管理器来获取队列消息。
此队列管理器中只有一个连接和通道。
昨天,我只在一个bean中做了一些更改。
当我开始使用消息时,它会给出异常“本地类不兼容”。我知道这个错误应该出现,但事实是,即使其他队列中有消息,其他参与者也会进入等待状态。
将4-5个队列绑定到单个通道是一种好的做法吗?或者,当一个队列对象被强制转换为异常时,在具有4-5个队列绑定的通道中发生异常时,这是一个错误。
有人能帮帮我吗?
发布于 2011-08-04 12:35:52
通道只是到RabbitMQ代理的多线程连接。所有队列使用者和消息发布者通常共享单个通道。无法理解的消息应该不会在通道上造成任何问题。
您使用的是哪种类型的交换?发布到exchange的邮件中包含哪种路由关键字?当您将队列绑定到交换时,您使用的是什么绑定密钥?
您是否考虑过在消息头中添加一个版本号,以便消息使用者知道应该使用哪个版本的java bean?这样他们就不需要在正常的工作过程中引发异常了。
https://stackoverflow.com/questions/5635010
复制相似问题