servicemix-commits mailing list archives

Author: gnodet
Date: Tue May  9 00:10:58 2006
New Revision: 405322

URL: http://svn.apache.org/viewcvs?rev=405322&view=rev
Log:
Add a unit test for URI epr resolution on servicemix-http

Added:
    incubator/servicemix/trunk/servicemix-http/src/test/java/org/apache/servicemix/http/HttpURITest.java
Modified:
    incubator/servicemix/trunk/servicemix-http/src/main/java/org/apache/servicemix/http/HttpSpringComponent.java

Modified: incubator/servicemix/trunk/servicemix-http/src/main/java/org/apache/servicemix/http/HttpSpringComponent.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-http/src/main/java/org/apache/servicemix/http/HttpSpringComponent.java?rev=405322&r1=405321&r2=405322&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-http/src/main/java/org/apache/servicemix/http/HttpSpringComponent.java
(original)
+++ incubator/servicemix/trunk/servicemix-http/src/main/java/org/apache/servicemix/http/HttpSpringComponent.java
Tue May  9 00:10:58 2006
@@ -70,9 +70,11 @@
             super.doInit();
             su = new ServiceUnit();
             su.setComponent(HttpSpringComponent.this);
-            for (int i = 0; i < endpoints.length; i++) {
-                endpoints[i].setServiceUnit(su);
-                su.addEndpoint(endpoints[i]);
+            if (endpoints != null) {
+	            for (int i = 0; i < endpoints.length; i++) {
+	                endpoints[i].setServiceUnit(su);
+	                su.addEndpoint(endpoints[i]);
+	            }
             }
             getRegistry().registerServiceUnit(su);
         }

Added: incubator/servicemix/trunk/servicemix-http/src/test/java/org/apache/servicemix/http/HttpURITest.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-http/src/test/java/org/apache/servicemix/http/HttpURITest.java?rev=405322&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-http/src/test/java/org/apache/servicemix/http/HttpURITest.java
(added)
+++ incubator/servicemix/trunk/servicemix-http/src/test/java/org/apache/servicemix/http/HttpURITest.java
Tue May  9 00:10:58 2006
@@ -0,0 +1,85 @@
+/*
+ * Copyright 2005-2006 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.servicemix.http;
+
+import java.util.List;
+
+import javax.jbi.messaging.ExchangeStatus;
+import javax.jbi.messaging.InOnly;
+import javax.jbi.messaging.MessageExchange;
+import javax.jbi.messaging.NormalizedMessage;
+import javax.jbi.servicedesc.ServiceEndpoint;
+
+import junit.framework.TestCase;
+
+import org.apache.servicemix.client.DefaultServiceMixClient;
+import org.apache.servicemix.jbi.container.JBIContainer;
+import org.apache.servicemix.jbi.jaxp.SourceTransformer;
+import org.apache.servicemix.jbi.jaxp.StringSource;
+import org.apache.servicemix.jbi.messaging.MessageExchangeSupport;
+import org.apache.servicemix.jbi.resolver.URIResolver;
+import org.apache.servicemix.tck.ReceiverComponent;
+import org.w3c.dom.Document;
+import org.w3c.dom.DocumentFragment;
+
+public class HttpURITest extends TestCase {
+
+	private JBIContainer jbi;
+	
+	protected void setUp() throws Exception {
+		jbi = new JBIContainer();
+		jbi.setEmbedded(true);
+		jbi.setUseMBeanServer(false);
+		jbi.init();
+		jbi.start();
+	}
+	
+	public void testResolveEndpoint() throws Exception {
+		HttpSpringComponent http = new HttpSpringComponent();
+		HttpEndpoint ep = new HttpEndpoint();
+		ep.setRole(MessageExchange.Role.CONSUMER);
+		ep.setService(ReceiverComponent.SERVICE);
+		ep.setEndpoint(ReceiverComponent.ENDPOINT);
+		ep.setLocationURI("http://localhost:8192/");
+		ep.setDefaultMep(MessageExchangeSupport.IN_ONLY);
+		http.setEndpoints(new HttpEndpoint[] { ep });
+		jbi.activateComponent(http, "servicemix-http");
+		
+		ReceiverComponent receiver = new ReceiverComponent();
+		jbi.activateComponent(receiver, "receiver");
+		
+		DefaultServiceMixClient client = new DefaultServiceMixClient(jbi);
+		DocumentFragment epr = URIResolver.createWSAEPR("http://localhost:8192?http.soap=true");
+		ServiceEndpoint se = client.getContext().resolveEndpointReference(epr);
+		assertNotNull(se);
+		
+		InOnly inonly = client.createInOnlyExchange();
+		inonly.setEndpoint(se);
+		inonly.getInMessage().setContent(new StringSource("<hello>world</hello>"));
+		client.sendSync(inonly);
+		
+		assertEquals(ExchangeStatus.DONE, inonly.getStatus());
+		receiver.getMessageList().assertMessagesReceived(1);
+		List msgs = receiver.getMessageList().flushMessages();
+		NormalizedMessage msg = (NormalizedMessage) msgs.get(0);
+		Document doc = (Document) new SourceTransformer().toDOMNode(msg);
+		assertEquals("http://www.w3.org/2003/05/soap-envelope", doc.getDocumentElement().getNamespaceURI());
+		assertEquals("env:Envelope", doc.getDocumentElement().getNodeName());
+		System.out.println(new SourceTransformer().contentToString(msg));
+		
+	}
+	
+}