You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by ay...@apache.org on 2013/06/20 18:33:30 UTC

svn commit: r1495088 - in /cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm: RMContextUtils.java RMInInterceptor.java

Author: ay
Date: Thu Jun 20 16:33:30 2013
New Revision: 1495088

URL: http://svn.apache.org/r1495088
Log:
minor fix on ws-rm's handling of non ws-rm messages

Modified:
    cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMContextUtils.java
    cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMInInterceptor.java

Modified: cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMContextUtils.java
URL: http://svn.apache.org/viewvc/cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMContextUtils.java?rev=1495088&r1=1495087&r2=1495088&view=diff
==============================================================================
--- cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMContextUtils.java (original)
+++ cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMContextUtils.java Thu Jun 20 16:33:30 2013
@@ -139,7 +139,6 @@ public final class RMContextUtils {
             ? RMMessageConstants.RM_PROPERTIES_OUTBOUND : RMMessageConstants.RM_PROPERTIES_INBOUND;
     }
 
-    //TODO put this key to the constant
     public static ProtocolVariation getProtocolVariation(Message message) {
         return (ProtocolVariation)message.get(RMMessageConstants.RM_PROTOCOL_VARIATION);
     }

Modified: cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMInInterceptor.java
URL: http://svn.apache.org/viewvc/cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMInInterceptor.java?rev=1495088&r1=1495087&r2=1495088&view=diff
==============================================================================
--- cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMInInterceptor.java (original)
+++ cxf/trunk/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/RMInInterceptor.java Thu Jun 20 16:33:30 2013
@@ -48,7 +48,8 @@ public class RMInInterceptor extends Abs
     @Override
     public void handleFault(Message message) {
         message.put(MAPAggregator.class.getName(), true);
-        if (MessageUtils.isTrue(message.get(RMMessageConstants.DELIVERING_ROBUST_ONEWAY))) {
+        if (RMContextUtils.getProtocolVariation(message) != null
+            && MessageUtils.isTrue(message.get(RMMessageConstants.DELIVERING_ROBUST_ONEWAY))) {
             // revert the delivering entry from the destination sequence
             try {
                 Destination destination = getManager().getDestination(message);