I have converted the camel-jetty test to a standard spring inegration
test. Interestingly I did not need the Camel test classes (at least for
this case).
The test already only starts the spring context once. I had to reset the
mock endpoint but that was the only change I had to do to avoid side
effects.
The source is attached below.
Any opinions?
Greetings
Christian
Am 05.03.2010 11:52, schrieb Christian Schneider:
Hi all,
I am currently debugging a little in the tests for jetty because I got
an error in a test.
While doing so I found out that the camel context or even the spring
context is (re)started for each test method. Wouldn´t it be much more
efficient to do this only per class?
I guess the tests could take less then half the time after this
change. What do you think?
Greetings
Christian
--
Christian Schneider
---
http://www.liquid-reality.de
------------------------
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You 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.camel.component.jetty;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import java.net.URL;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import org.apache.camel.EndpointInject;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.apache.camel.test.junit4.TestSupport;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations={"/org/apache/camel/component/jetty/jetty-https.xml"})
public class SpringHttpsRouteTest {
private static final String NULL_VALUE_MARKER =
CamelTestSupport.class.getCanonicalName();
protected String expectedBody = "<hello>world!</hello>";
protected String pwd = "changeit";
protected Properties originalValues = new Properties();
protected transient Log log = LogFactory.getLog(TestSupport.class);
@EndpointInject(uri="mock:a")
MockEndpoint mockEndpoint;
@Produce
private ProducerTemplate template;
@Before
public void setUp() throws Exception {
// ensure jsse clients can validate the self signed dummy localhost
cert,
// use the server keystore as the trust store for these tests
URL trustStoreUrl =
Thread.currentThread().getContextClassLoader().getResource("jsse/localhost.ks");
setSystemProp("javax.net.ssl.trustStore", trustStoreUrl.getPath());
}
@After
public void tearDown() throws Exception {
restoreSystemProperties();
}
private void setSystemProp(String key, String value) {
String originalValue = System.setProperty(key, value);
originalValues.put(key, originalValue != null ? originalValue :
NULL_VALUE_MARKER);
}
private void restoreSystemProperties() {
for (Object key : originalValues.keySet()) {
Object value = (String) originalValues.get(key);
if (NULL_VALUE_MARKER.equals(value)) {
System.getProperties().remove(key);
} else {
System.setProperty((String) key, (String) value);
}
}
}
@Test
public void testEndpoint() throws Exception {
mockEndpoint.reset();
mockEndpoint.expectedBodiesReceived(expectedBody);
template.sendBodyAndHeader("https://localhost:9080/test";, expectedBody,
"Content-Type", "application/xml");
mockEndpoint.assertIsSatisfied();
List<Exchange> list = mockEndpoint.getReceivedExchanges();
Exchange exchange = list.get(0);
TestSupport.assertNotNull("exchange", exchange);
Message in = exchange.getIn();
assertNotNull("in", in);
Map<String, Object> headers = in.getHeaders();
log.info("Headers: " + headers);
assertTrue("Should be more than one header but was: " + headers,
headers.size()> 0);
}
@Test
public void testEndpointWithoutHttps() {
mockEndpoint.reset();
try {
template.sendBodyAndHeader("http://localhost:9080/test";, expectedBody,
"Content-Type", "application/xml");
fail("expect exception on access to https endpoint via http");
} catch (RuntimeCamelException expected) {
}
assertTrue("mock endpoint was not called",
mockEndpoint.getExchanges().isEmpty());
}
}
