svn commit: r687260 - /activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/customerrelations/CustomerServicesTest.java

[ni...@apache.org]

Author: ningjiang
Date: Tue Aug 19 23:13:02 2008
New Revision: 687260

URL: http://svn.apache.org/viewvc?rev=687260&view=rev
Log:
CAMEL-835 Fixed the CustomerServicesTest failure

Modified:
    activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/customerrelations/CustomerServicesTest.java

Modified: activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/customerrelations/CustomerServicesTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/customerrelations/CustomerServicesTest.java?rev=687260&r1=687259&r2=687260&view=diff
==============================================================================
--- activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/customerrelations/CustomerServicesTest.java (original)
+++ activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/customerrelations/CustomerServicesTest.java Tue Aug 19 23:13:02 2008
@@ -41,19 +41,21 @@
                 new String[] {"spring-config/server-applicationContext.xml"});
             Object server = serverContext.getBean("org.apache.camel.itest.customerrelations.CustomerServiceV1");
             assertNotNull("We should get server here", server);
-            
+
             // add an interceptor to verify headers
             EndpointImpl.class.cast(server).getServer().getEndpoint().getInInterceptors()
-                .add(new HeaderChecker(Phase.PRE_STREAM));
-            
+                .add(new HeaderChecker(Phase.READ));
+
             clientContext =  new ClassPathXmlApplicationContext(
                 new String[] {"spring-config/client-applicationContext.xml"});
             CustomerServiceV1 customerService = (CustomerServiceV1) clientContext.getBean("org.apache.camel.itest.customerrelations.CustomerServiceV1");
-            
-            // add an interceptor to verify headers
-            JaxWsClientProxy.class.cast(Proxy.getInvocationHandler(customerService))
-                .getClient().getInInterceptors().add(new HeaderChecker(Phase.PRE_STREAM));
-            
+
+            // CXF 2.1.2 only apply the SOAPAction for the request message (in SoapPreProtocolOutInterceptor)
+            // After went through the SOAP 1.1 specification, I got that the SOAPAction is only for the request message
+            // So I comment out this HeaderChecker Interceptor setting up code
+            /*JaxWsClientProxy.class.cast(Proxy.getInvocationHandler(customerService))
+                .getClient().getInInterceptors().add(new HeaderChecker(Phase.READ));*/
+
             Customer customer = customerService.getCustomer("12345");
             assertNotNull("We should get Customer here", customer);
         } finally {
@@ -65,17 +67,17 @@
             }
         }
     }
-    
+
     class HeaderChecker extends AbstractPhaseInterceptor<Message> {
         public HeaderChecker(String phase) {
             super(phase);
         }
-        
+
         public void handleMessage(Message message) throws Fault {
-            Map<String, List<String>> headers 
+            Map<String, List<String>> headers
                 = CastUtils.cast((Map<?, ?>)message.get(Message.PROTOCOL_HEADERS));
             assertNotNull(headers);
             assertEquals("\"getCustomer\"", headers.get("SOAPAction").get(0));
-        }   
+        }
     }
 }