Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-28 13:19:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

AMQ-6924 - Fix StoreDurableSubscriberCursor non-persistent message add

Browse Source 
StoreDurableSubscriberCursor now properly uses a timeout value when
attempting to add to the temporary store for non-persistent messages to
prevent an indefinite wait on free space

(cherry picked from commit 5e2adc0ed7dfe2e827bdef878f1c8cde12ff5773)
This commit is contained in:
Christopher L. Shannon (cshannon) 2018-03-09 07:39:45 -05:00
parent d6b703bcb1
commit 2ca46c561b
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
View File

@ -188,7 +188,7 @@ public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
Message msg = node.getMessage(); Message msg = node.getMessage();
if (isStarted()) { if (isStarted()) {
if (!msg.isPersistent()) { if (!msg.isPersistent()) {
nonPersistent.addMessageLast(node); nonPersistent.tryAddMessageLast(node, wait);
} }
} }
if (msg.isPersistent()) { if (msg.isPersistent()) {