发送消息后,不会清除 ActiveMQ 消息内容



>我有java应用程序,其中有一个发送方和接收方以及ActiveMQ队列发送方创建消息并将其发送到队列,使用者从那里使用消息。每次我发送消息时,它都会被序列化,其内容包含消息的ByteSequence,队列获取该消息并且消费者使用它,但是,我发现每次我向队列发送消息时,ByteSequence都不会从内存中清除,最终我得到了OutOfMemoryException

消息发送到队列后,不应该从生产者中删除吗?

谢谢!

看起来 Q 正在使用预取默认值 1000,这导致消费者出现 OOM 异常,因为每条消息的处理时间太长,预取只是很快被填满

最新更新