【问题标题】:ActiveMQ message content is not cleared after the message is sentActiveMQ 消息发送后不清除消息内容
【发布时间】:2019-06-11 16:08:23
【问题描述】:

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

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

谢谢!

【问题讨论】:

标签: java memory-leaks activemq message-queue


【解决方案1】:

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

【讨论】:

    猜你喜欢
    • 2013-06-25
    • 1970-01-01
    • 1970-01-01
    • 2012-09-10
    • 1970-01-01
    • 1970-01-01
    • 2021-11-13
    • 2021-12-30
    • 1970-01-01
    相关资源
    最近更新 更多