消息发送后ActiveMQ消息内容未清空
ActiveMQ message content is not cleared after the message is sent
我有 java 应用程序，其中有发送方和接收方以及 ActiveMQ 队列
发件人创建消息并将它们发送到队列，消费者从那里消费消息。
每次我发送一条消息时，它都会被序列化，并且它的内容包含消息的 ByteSequence ，并且 Queue 获取该消息并且消费者使用它但是，我发现每次我向 Queue 发送消息时，ByteSequence 没有从内存中清除，最终我得到 OutOfMemoryException
消息发送到Queue后是否应该从producer中删除？
谢谢！
好吧，看来 Q 使用的是预取默认值 1000，这导致消费者出现 OOM 异常，因为每条消息的处理时间太长，预取只能快速填充
我有 java 应用程序，其中有发送方和接收方以及 ActiveMQ 队列
发件人创建消息并将它们发送到队列，消费者从那里消费消息。
每次我发送一条消息时，它都会被序列化，并且它的内容包含消息的 ByteSequence ，并且 Queue 获取该消息并且消费者使用它但是，我发现每次我向 Queue 发送消息时，ByteSequence 没有从内存中清除，最终我得到 OutOfMemoryException
消息发送到Queue后是否应该从producer中删除？
谢谢！
好吧，看来 Q 使用的是预取默认值 1000，这导致消费者出现 OOM 异常，因为每条消息的处理时间太长，预取只能快速填充