[ 
https://issues.apache.org/jira/browse/AMQ-4971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13873301#comment-13873301
 ] 

Gary Tully commented on AMQ-4971:
---------------------------------

the prefetch should limit the number of messages pending an ack at one time. 

try{code}<networkConnector .... prefetchSize="1" .../>{code}


> OOM in DemandForwardingBridge
> -----------------------------
>
>                 Key: AMQ-4971
>                 URL: https://issues.apache.org/jira/browse/AMQ-4971
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.9.0
>            Reporter: Yuriy Sidelnikov
>              Labels: features
>         Attachments: AMQ-4971.patch
>
>
> DemandForwardingBridge sends messages to the other broker and asynchronously 
> waits for ACKs keeping message bodies in heap. Amount of un-ACK-ed messages 
> kept in heap is not limited. If local producer is fast then whole heap will 
> be consumed by messages waiting to be ACK-ed by other broker.
> Possible option to fix the issue:
> Don't wait for ACK from other broker when forwarding the message if some 
> threshold of un-ACK-ed messages is reached.



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)

Reply via email to