Return-Path: Delivered-To: apmail-camel-commits-archive@www.apache.org Received: (qmail 79412 invoked from network); 26 Mar 2010 05:46:34 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 26 Mar 2010 05:46:34 -0000 Received: (qmail 34368 invoked by uid 500); 26 Mar 2010 05:46:33 -0000 Delivered-To: apmail-camel-commits-archive@camel.apache.org Received: (qmail 34318 invoked by uid 500); 26 Mar 2010 05:46:32 -0000 Mailing-List: contact commits-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@camel.apache.org Delivered-To: mailing list commits@camel.apache.org Received: (qmail 34311 invoked by uid 99); 26 Mar 2010 05:46:31 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 26 Mar 2010 05:46:31 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 26 Mar 2010 05:46:29 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 32F9F23889D2; Fri, 26 Mar 2010 05:46:09 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r927698 [2/2] - in /camel/trunk: components/ components/camel-netty/ components/camel-netty/src/ components/camel-netty/src/main/ components/camel-netty/src/main/java/ components/camel-netty/src/main/java/org/ components/camel-netty/src/mai... Date: Fri, 26 Mar 2010 05:46:08 -0000 To: commits@camel.apache.org From: akarpe@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20100326054609.32F9F23889D2@eris.apache.org> Added: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPAsyncTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPAsyncTest.java?rev=927698&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPAsyncTest.java (added) +++ camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPAsyncTest.java Fri Mar 26 05:46:07 2010 @@ -0,0 +1,90 @@ +/** + * 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 java.io.BufferedInputStream; +import java.io.FileInputStream; +import java.io.InputStream; + +import org.apache.camel.EndpointInject; +import org.apache.camel.Exchange; +import org.apache.camel.Message; +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.component.mock.MockEndpoint; +import org.apache.camel.converter.IOConverter; +import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.junit.Test; + +public class NettyTCPAsyncTest extends CamelTestSupport { + private static final transient Log LOG = LogFactory.getLog(NettyTCPAsyncTest.class); + + @EndpointInject(uri = "mock:result") + protected MockEndpoint resultEndpoint; + @Produce(uri = "direct:start") + protected ProducerTemplate producerTemplate; + + private void sendFile(String uri) throws Exception { + producerTemplate.send(uri, new Processor() { + public void process(Exchange exchange) throws Exception { + // Read from an input stream + InputStream is = new BufferedInputStream( + new FileInputStream("./src/test/resources/test.txt")); + + byte buffer[] = IOConverter.toBytes(is); + is.close(); + + // Set the property of the charset encoding + exchange.setProperty(Exchange.CHARSET_NAME, "UTF-8"); + Message in = exchange.getIn(); + in.setBody(buffer); + } + }); + } + + @Test + public void testTCPInOnlyWithNettyConsumer() throws Exception { + if (LOG.isDebugEnabled()) { + LOG.debug("Beginning Test ---> testTCPInOnlyWithNettyConsumer()"); + } + + MockEndpoint mock = getMockEndpoint("mock:result"); + mock.expectedMessageCount(1); + sendFile("netty:tcp://localhost:5150"); + + mock.assertIsSatisfied(); + if (LOG.isDebugEnabled()) { + LOG.debug("Completed Test ---> testTCPInOnlyWithNettyConsumer()"); + } + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("netty:tcp://localhost:5150") + .to("mock:result"); + } + }; + } + +} Propchange: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPAsyncTest.java ------------------------------------------------------------------------------ svn:eol-style = native Added: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPSyncTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPSyncTest.java?rev=927698&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPSyncTest.java (added) +++ camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPSyncTest.java Fri Mar 26 05:46:07 2010 @@ -0,0 +1,87 @@ +/** + * 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.test.junit4.CamelTestSupport; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.junit.Test; + +public class NettyTCPSyncTest extends CamelTestSupport { + private static final transient Log LOG = LogFactory.getLog(NettyTCPSyncTest.class); + + @Produce(uri = "direct:start") + protected ProducerTemplate producerTemplate; + + @Test + public void testTCPStringInOutWithNettyConsumer() throws Exception { + if (LOG.isDebugEnabled()) { + LOG.debug("Beginning Test ---> testTCPInOutWithNettyConsumer()"); + } + + String response = producerTemplate.requestBody( + "netty:tcp://localhost:5150?sync=true", + "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); + + if (LOG.isDebugEnabled()) { + LOG.debug("Completed Test ---> testTCPInOutWithNettyConsumer()"); + } + } + + @Test + public void testTCPObjectInOutWithNettyConsumer() throws Exception { + if (LOG.isDebugEnabled()) { + LOG.debug("Beginning Test ---> testUDPInOutWithNettyConsumer()"); + } + + Poetry poetry = new Poetry(); + Poetry response = (Poetry) producerTemplate.requestBody("netty:tcp://localhost:5150?sync=true", poetry); + assertEquals("Dr. Sarojini Naidu", response.getPoet()); + + if (LOG.isDebugEnabled()) { + LOG.debug("Completed Test ---> testUDPInOutWithNettyConsumer()"); + } + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("netty:tcp://localhost:5150?sync=true") + .process(new Processor() { + public void process(Exchange exchange) throws Exception { + if (exchange.getIn().getBody() instanceof Poetry) { + Poetry poetry = (Poetry) exchange.getIn().getBody(); + poetry.setPoet("Dr. Sarojini Naidu"); + exchange.getOut().setBody(poetry); + return; + } + exchange.getOut().setBody("When You Go Home, Tell Them Of Us And Say, For Your Tomorrow, We Gave Our Today."); + } + }); + } + }; + } + +} Propchange: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTCPSyncTest.java ------------------------------------------------------------------------------ svn:eol-style = native Added: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPAsyncTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPAsyncTest.java?rev=927698&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPAsyncTest.java (added) +++ camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPAsyncTest.java Fri Mar 26 05:46:07 2010 @@ -0,0 +1,92 @@ +/** + * 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 java.io.BufferedInputStream; +import java.io.FileInputStream; +import java.io.InputStream; + +import org.apache.camel.EndpointInject; +import org.apache.camel.Exchange; +import org.apache.camel.Message; +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.component.mock.MockEndpoint; +import org.apache.camel.converter.IOConverter; +import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.junit.Test; + +public class NettyUDPAsyncTest extends CamelTestSupport { + private static final transient Log LOG = LogFactory.getLog(NettyUDPAsyncTest.class); + + @EndpointInject(uri = "mock:result") + protected MockEndpoint resultEndpoint; + @Produce(uri = "direct:start") + protected ProducerTemplate producerTemplate; + + private void sendFile(String uri) throws Exception { + producerTemplate.send(uri, new Processor() { + public void process(Exchange exchange) throws Exception { + // Read from an input stream + InputStream is = new BufferedInputStream( + new FileInputStream("./src/test/resources/test.txt")); + + byte buffer[] = IOConverter.toBytes(is); + is.close(); + + // Set the property of the charset encoding + exchange.setProperty(Exchange.CHARSET_NAME, "UTF-8"); + Message in = exchange.getIn(); + in.setBody(buffer); + } + }); + } + + @Test + public void testUDPInOnlyWithNettyConsumer() throws Exception { + if (LOG.isDebugEnabled()) { + LOG.debug("Beginning Test ---> testUDPInOnlyWithNettyConsumer()"); + } + + MockEndpoint mock = getMockEndpoint("mock:result"); + mock.expectedMessageCount(1); + sendFile("netty:udp://localhost:5151"); + mock.assertIsSatisfied(); + + if (LOG.isDebugEnabled()) { + LOG.debug("Completed Test ---> testUDPInOnlyWithNettyConsumer()"); + } + } + + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("netty:udp://localhost:5151") + .to("mock:result") + .to("log:Message"); + } + }; + } + +} Propchange: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPAsyncTest.java ------------------------------------------------------------------------------ svn:eol-style = native Added: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPObjectSyncTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPObjectSyncTest.java?rev=927698&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPObjectSyncTest.java (added) +++ camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPObjectSyncTest.java Fri Mar 26 05:46:07 2010 @@ -0,0 +1,67 @@ +/** + * 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.test.junit4.CamelTestSupport; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.junit.Test; + +public class NettyUDPObjectSyncTest extends CamelTestSupport { + private static final transient Log LOG = LogFactory.getLog(NettyUDPObjectSyncTest.class); + + @Produce(uri = "direct:start") + protected ProducerTemplate producerTemplate; + + @Test + public void testUDPObjectInOutWithNettyConsumer() throws Exception { + if (LOG.isDebugEnabled()) { + LOG.debug("Beginning Test ---> testUDPInOutWithNettyConsumer()"); + } + + Poetry poetry = new Poetry(); + Poetry response = producerTemplate.requestBody("netty:udp://localhost:5155?sync=true", poetry, Poetry.class); + assertEquals("Dr. Sarojini Naidu", response.getPoet()); + + if (LOG.isDebugEnabled()) { + LOG.debug("Completed Test ---> testUDPInOutWithNettyConsumer()"); + } + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("netty:udp://localhost:5155?sync=true") + .process(new Processor() { + public void process(Exchange exchange) throws Exception { + Poetry poetry = (Poetry) exchange.getIn().getBody(); + poetry.setPoet("Dr. Sarojini Naidu"); + exchange.getOut().setBody(poetry); + } + }); + } + }; + } + +} Propchange: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPObjectSyncTest.java ------------------------------------------------------------------------------ svn:eol-style = native Added: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPSyncTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPSyncTest.java?rev=927698&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPSyncTest.java (added) +++ camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPSyncTest.java Fri Mar 26 05:46:07 2010 @@ -0,0 +1,70 @@ +/** + * 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.test.junit4.CamelTestSupport; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.junit.Test; + +public class NettyUDPSyncTest extends CamelTestSupport { + private static final transient Log LOG = LogFactory.getLog(NettyUDPSyncTest.class); + + @Produce(uri = "direct:start") + protected ProducerTemplate producerTemplate; + + @Test + public void testUDPStringInOutWithNettyConsumer() throws Exception { + + if (LOG.isDebugEnabled()) { + LOG.debug("Beginning Test ---> testUDPInOutWithNettyConsumer()"); + } + + for (int i = 0; i < 5; i++) { + String response = producerTemplate.requestBody( + "netty:udp://localhost:5152?sync=true", + "After the Battle of Thermopylae in 480 BC - Simonides of Ceos (c. 556 BC-468 BC), Greek lyric poet wrote ?", String.class); + assertEquals("Go tell the Spartans, thou that passest by, That faithful to their precepts here we lie.", response); + } + + if (LOG.isDebugEnabled()) { + LOG.debug("Completed Test ---> testUDPInOutWithNettyConsumer()"); + } + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("netty:udp://localhost:5152?sync=true") + .process(new Processor() { + public void process(Exchange exchange) throws Exception { + exchange.getOut().setBody("Go tell the Spartans, thou that passest by, That faithful to their precepts here we lie."); + } + }); + } + }; + } + + +} Propchange: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUDPSyncTest.java ------------------------------------------------------------------------------ svn:eol-style = native Added: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Poetry.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Poetry.java?rev=927698&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Poetry.java (added) +++ camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Poetry.java Fri Mar 26 05:46:07 2010 @@ -0,0 +1,57 @@ +/** + * 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 java.io.Serializable; + +public class Poetry implements Serializable { + private static final long serialVersionUID = 1L; + private String poet = "?"; + private String poem = "ONCE in the dream of a night I stood\n" + + "Lone in the light of a magical wood,\n" + + "Soul-deep in visions that poppy-like sprang;\n" + + "And spirits of Truth were the birds that sang,\n" + + "And spirits of Love were the stars that glowed,\n" + + "And spirits of Peace were the streams that flowed\n" + + "In that magical wood in the land of sleep." + + "\n" + + "Lone in the light of that magical grove,\n" + + "I felt the stars of the spirits of Love\n" + + "Gather and gleam round my delicate youth,\n" + + "And I heard the song of the spirits of Truth;\n" + + "To quench my longing I bent me low\n" + + "By the streams of the spirits of Peace that flow\n" + + "In that magical wood in the land of sleep."; + + public String getPoet() { + return poet; + } + + public void setPoet(String poet) { + this.poet = poet; + } + + public String getPoem() { + return poem; + } + + public void setPoem(String poem) { + this.poem = poem; + } + +} Propchange: camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Poetry.java ------------------------------------------------------------------------------ svn:eol-style = native Added: camel/trunk/components/camel-netty/src/test/resources/log4j.properties URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/resources/log4j.properties?rev=927698&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/resources/log4j.properties (added) +++ camel/trunk/components/camel-netty/src/test/resources/log4j.properties Fri Mar 26 05:46:07 2010 @@ -0,0 +1,38 @@ +## ------------------------------------------------------------------------ +## 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. +## ------------------------------------------------------------------------ + +# +# The logging properties used for eclipse testing, We want to see debug output on the console. +# +log4j.rootLogger=DEBUG, file + +# uncomment the following to enable camel debugging +log4j.logger.org.apache.camel.component.netty=DEBUG +log4j.logger.org.apache.camel=DEBUG +log4j.logger.org.apache.commons.net=TRACE + +# CONSOLE appender not used by default +log4j.appender.out=org.apache.log4j.ConsoleAppender +log4j.appender.out.layout=org.apache.log4j.PatternLayout +#log4j.appender.out.layout.ConversionPattern=[%30.30t] %-30.30c{1} %-5p %m%n +log4j.appender.out.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n + +# File appender +log4j.appender.file=org.apache.log4j.FileAppender +log4j.appender.file.layout=org.apache.log4j.PatternLayout +log4j.appender.file.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n +log4j.appender.file.file=target/camel-netty-test.log \ No newline at end of file Propchange: camel/trunk/components/camel-netty/src/test/resources/log4j.properties ------------------------------------------------------------------------------ svn:eol-style = native Added: camel/trunk/components/camel-netty/src/test/resources/test.txt URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/resources/test.txt?rev=927698&view=auto ============================================================================== --- camel/trunk/components/camel-netty/src/test/resources/test.txt (added) +++ camel/trunk/components/camel-netty/src/test/resources/test.txt Fri Mar 26 05:46:07 2010 @@ -0,0 +1,19 @@ +Song Of A Dream +by: Dr Sarojini Naidu + +ONCE in the dream of a night I stood +Lone in the light of a magical wood, +Soul-deep in visions that poppy-like sprang; +And spirits of Truth were the birds that sang, +And spirits of Love were the stars that glowed, +And spirits of Peace were the streams that flowed +In that magical wood in the land of sleep. + + +Lone in the light of that magical grove, +I felt the stars of the spirits of Love +Gather and gleam round my delicate youth, +And I heard the song of the spirits of Truth; +To quench my longing I bent me low +By the streams of the spirits of Peace that flow +In that magical wood in the land of sleep. \ No newline at end of file Propchange: camel/trunk/components/camel-netty/src/test/resources/test.txt ------------------------------------------------------------------------------ svn:eol-style = native Modified: camel/trunk/components/pom.xml URL: http://svn.apache.org/viewvc/camel/trunk/components/pom.xml?rev=927698&r1=927697&r2=927698&view=diff ============================================================================== --- camel/trunk/components/pom.xml (original) +++ camel/trunk/components/pom.xml Fri Mar 26 05:46:07 2010 @@ -74,6 +74,7 @@ camel-mina camel-msv camel-mvel + camel-netty camel-nagios camel-ognl camel-osgi Modified: camel/trunk/parent/pom.xml URL: http://svn.apache.org/viewvc/camel/trunk/parent/pom.xml?rev=927698&r1=927697&r2=927698&view=diff ============================================================================== --- camel/trunk/parent/pom.xml (original) +++ camel/trunk/parent/pom.xml Fri Mar 26 05:46:07 2010 @@ -91,6 +91,7 @@ 3.0.1 1.1.7 1.8.2 + 3.1.5.GA 2.7.3_3 1.2.2 1.2.0