Author: dvaleri Date: Fri Oct 21 14:40:19 2011 New Revision: 1187373 URL: http://svn.apache.org/viewvc?rev=1187373&view=rev Log: [CAMEL-4572] Added missing unit test coverage for Netty SSLContextParameters support.
Added: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettySSLContextParametersTest.java (with props) Added: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettySSLContextParametersTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettySSLContextParametersTest.java?rev=1187373&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettySSLContextParametersTest.java (added) +++ camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettySSLContextParametersTest.java Fri Oct 21 14:40:19 2011 @@ -0,0 +1,95 @@ +/** + * 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.netty; + +import org.apache.camel.Exchange; +import org.apache.camel.Processor; +import org.apache.camel.Produce; +import org.apache.camel.ProducerTemplate; +import org.apache.camel.builder.RouteBuilder; +import org.apache.camel.impl.JndiRegistry; +import org.apache.camel.util.jsse.KeyManagersParameters; +import org.apache.camel.util.jsse.KeyStoreParameters; +import org.apache.camel.util.jsse.SSLContextParameters; +import org.apache.camel.util.jsse.TrustManagersParameters; +import org.junit.Test; + +public class NettySSLContextParametersTest extends BaseNettyTest { + @Produce(uri = "direct:start") + protected ProducerTemplate producerTemplate; + + @Override + protected JndiRegistry createRegistry() throws Exception { + + KeyStoreParameters ksp = new KeyStoreParameters(); + ksp.setResource(this.getClass().getClassLoader().getResource("keystore.jks").toString()); + ksp.setPassword("changeit"); + + KeyManagersParameters kmp = new KeyManagersParameters(); + kmp.setKeyPassword("changeit"); + kmp.setKeyStore(ksp); + + TrustManagersParameters tmp = new TrustManagersParameters(); + tmp.setKeyStore(ksp); + + SSLContextParameters sslContextParameters = new SSLContextParameters(); + sslContextParameters.setKeyManagers(kmp); + sslContextParameters.setTrustManagers(tmp); + + JndiRegistry registry = super.createRegistry(); + registry.bind("sslContextParameters", sslContextParameters); + return registry; + } + + @Override + public boolean isUseRouteBuilder() { + return false; + } + + private void sendRequest() throws Exception { + String response = producerTemplate.requestBody( + "netty:tcp://localhost:{{port}}?sync=true&ssl=true&sslContextParameters=#sslContextParameters", + "Epitaph in Kohima, India marking the WWII Battle of Kohima and Imphal, Burma Campaign - Attributed to John Maxwell Edmonds", String.class); + assertEquals("When You Go Home, Tell Them Of Us And Say, For Your Tomorrow, We Gave Our Today.", response); + } + + + @Test + public void testSSLInOutWithNettyConsumer() throws Exception { + // ibm jdks dont have sun security algorithms + if (isJavaVendor("ibm")) { + return; + } + + context.addRoutes(new RouteBuilder() { + public void configure() { + from("netty:tcp://localhost:{{port}}?sync=true&ssl=true&sslContextParameters=#sslContextParameters") + .process(new Processor() { + public void process(Exchange exchange) throws Exception { + exchange.getOut().setBody("When You Go Home, Tell Them Of Us And Say, For Your Tomorrow, We Gave Our Today."); + } + }); + } + }); + context.start(); + + sendRequest(); + context.stop(); + } + +} Propchange: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettySSLContextParametersTest.java ------------------------------------------------------------------------------ svn:eol-style = native