AMQ-6924 - Fix StoreDurableSubscriberCursor non-persistent message add

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
This commit is contained in:
Christopher L. Shannon (cshannon) 2018-03-09 07:39:45 -05:00
parent 0bb4a5c3ab
commit 5e2adc0ed7
1 changed files with 1 additions and 1 deletions

View File

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