cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r615104 - /incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/mtom/MtomServerTest.java
Date Fri, 25 Jan 2008 04:32:06 GMT
Author: ningjiang
Date: Thu Jan 24 20:32:04 2008
New Revision: 615104

URL: http://svn.apache.org/viewvc?rev=615104&view=rev
Log:
CXF-1401 Fixed the MtomServerTest warning complain

Modified:
    incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/mtom/MtomServerTest.java

Modified: incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/mtom/MtomServerTest.java
URL: http://svn.apache.org/viewvc/incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/mtom/MtomServerTest.java?rev=615104&r1=615103&r2=615104&view=diff
==============================================================================
--- incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/mtom/MtomServerTest.java
(original)
+++ incubator/cxf/trunk/systests/src/test/java/org/apache/cxf/systest/mtom/MtomServerTest.java
Thu Jan 24 20:32:04 2008
@@ -53,20 +53,20 @@
 import org.junit.Test;
 
 public class MtomServerTest extends AbstractCXFTest {
-   
-    
+
+
     private static final String HTTP_ID = "http://schemas.xmlsoap.org/wsdl/http/";
-    
+
     @BeforeClass
     public static void setKeepAliveProperty() {
         TestUtilities.setKeepAliveSystemProperty(false);
     }
-    
+
     @AfterClass
     public static void cleanKeepAliveProperty() {
         TestUtilities.recoverKeepAliveSystemProperty();
     }
-    
+
     @Test
     public void testMtomRequest() throws Exception {
         JaxWsServerFactoryBean sf = new JaxWsServerFactoryBean();
@@ -78,7 +78,7 @@
         props.put(Message.MTOM_ENABLED, "true");
         sf.setProperties(props);
         sf.create();
-        
+
         EndpointInfo ei = new EndpointInfo(null, HTTP_ID);
         ei.setAddress(address);
 
@@ -141,11 +141,9 @@
         sf.setProperties(props);
         Server server = sf.create();
         server.getEndpoint().getService().getDataBinding().setMtomThreshold(0);
-        
-        servStatic(getClass().getResource("mtom-policy.xml"), 
-                   "http://localhost:9036/policy.xsd");
-        
 
+        servStatic(getClass().getResource("mtom-policy.xml"),
+                   "http://localhost:9036/policy.xsd");
 
         EndpointInfo ei = new EndpointInfo(null, HTTP_ID);
         ei.setAddress(address);
@@ -156,7 +154,7 @@
 
         TestMessageObserver obs = new TestMessageObserver();
         conduit.setMessageObserver(obs);
-        
+
         Message m = new MessageImpl();
         String ct = "multipart/related; type=\"application/xop+xml\"; "
                     + "start=\"<soap.xml@xfire.codehaus.org>\"; "
@@ -177,7 +175,7 @@
         os.flush();
         is.close();
         os.close();
-        
+
         byte[] res = obs.getResponseStream().toByteArray();
         MessageImpl resMsg = new MessageImpl();
         resMsg.setContent(InputStream.class, new ByteArrayInputStream(res));
@@ -197,17 +195,33 @@
         assertTrue("Wrong size: " + out.size()
                    + "\n" + out.toString(),
                    out.size() > 970 && out.size() < 1020);
+        unregisterServStatic("http://localhost:9036/policy.xsd");
+
+    }
+
+    private void unregisterServStatic(String add) throws Exception {
+        Bus bus = getBus();
+        DestinationFactoryManager dfm = bus.getExtension(DestinationFactoryManager.class);
+        DestinationFactory df = dfm
+            .getDestinationFactory("http://cxf.apache.org/transports/http/configuration");
+
+        EndpointInfo ei = new EndpointInfo();
+        ei.setAddress(add);
+
+        Destination d = df.getDestination(ei);
+        d.setMessageObserver(null);
+
     }
 
     @Override
     protected Bus createBus() throws BusException {
         return BusFactory.getDefaultBus();
     }
-    
+
     /**
      * Serve static file
      */
-    private void servStatic(final URL resource, 
+    private void servStatic(final URL resource,
                                    final String add) throws Exception {
         Bus bus = getBus();
         DestinationFactoryManager dfm = bus.getExtension(DestinationFactoryManager.class);



Mime
View raw message