cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dk...@apache.org
Subject [1/5] cxf git commit: Fix test
Date Wed, 16 Aug 2017 18:55:50 GMT
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 <dkulp@apache.org>
Authored: Wed Aug 16 14:21:17 2017 -0400
Committer: Daniel Kulp <dkulp@apache.org>
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) {


Mime
View raw message