Repository: cxf Updated Branches: refs/heads/master 56fc03c41 -> e9a8d1ac4
Fix test Project: http://git-wip-us.apache.org/repos/asf/cxf/repo Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/b0399bf5 Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/b0399bf5 Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/b0399bf5 Branch: refs/heads/master Commit: b0399bf5230754ea7edb97efc11804c255bf2d15 Parents: bcb6385 Author: Daniel Kulp <[email protected]> Authored: Wed Aug 16 14:21:17 2017 -0400 Committer: Daniel Kulp <[email protected]> Committed: Wed Aug 16 14:22:17 2017 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/cxf/ws/rm/DestinationSequence.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cxf/blob/b0399bf5/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java ---------------------------------------------------------------------- diff --git a/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java b/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java index b45020f..886ad6e 100644 --- a/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java +++ b/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java @@ -33,6 +33,7 @@ import java.util.logging.Level; import java.util.logging.Logger; import org.apache.cxf.common.logging.LogUtils; +import org.apache.cxf.common.util.PropertyUtils; import org.apache.cxf.continuations.Continuation; import org.apache.cxf.continuations.ContinuationProvider; import org.apache.cxf.continuations.SuspendedInvocationException; @@ -183,7 +184,7 @@ public class DestinationSequence extends AbstractSequence { if (updated) { RMStore store = destination.getManager().getStore(); - if (null != store && !MessageUtils.getContextualBoolean(message, Message.ROBUST_ONEWAY, false)) { + if (null != store && !MessageUtils.getContextualBoolean(message, Message.ROBUST_ONEWAY)) { try { RMMessage msg = new RMMessage(); CachedOutputStream cos = (CachedOutputStream)message @@ -272,10 +273,10 @@ public class DestinationSequence extends AbstractSequence { boolean robustDelivering = false; boolean inOrder = mn - nextInOrder == 1; if (message != null) { - robust = MessageUtils.getContextualBoolean(message, Message.ROBUST_ONEWAY, false); + robust = MessageUtils.getContextualBoolean(message, Message.ROBUST_ONEWAY); if (robust) { robustDelivering = - MessageUtils.getContextualBoolean(message, RMMessageConstants.DELIVERING_ROBUST_ONEWAY, false); + PropertyUtils.isTrue(message.get(RMMessageConstants.DELIVERING_ROBUST_ONEWAY)); } } if (robust && !robustDelivering) {
