camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r810847 - /camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyAsyncWithThreadsTest.java
Date Thu, 03 Sep 2009 09:40:58 GMT
Author: davsclaus
Date: Thu Sep  3 09:40:58 2009
New Revision: 810847

URL: http://svn.apache.org/viewvc?rev=810847&view=rev
Log:
Added unit test with jetty and doing async using threads

Added:
    camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyAsyncWithThreadsTest.java
  (with props)

Added: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyAsyncWithThreadsTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyAsyncWithThreadsTest.java?rev=810847&view=auto
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyAsyncWithThreadsTest.java
(added)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyAsyncWithThreadsTest.java
Thu Sep  3 09:40:58 2009
@@ -0,0 +1,150 @@
+/**
+ * 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 org.apache.camel.Exchange;
+import org.apache.camel.ExchangePattern;
+import org.apache.camel.Processor;
+import org.apache.camel.WaitForTaskToComplete;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.test.junit4.CamelTestSupport;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * @version $Revision$
+ */
+public class JettyAsyncWithThreadsTest extends CamelTestSupport {
+
+    private static final String ENDPOINT_NAME = "http://localhost:9876/asyncRouteTest";
+	private static String route = "";
+
+    @Before
+    public void setUp() throws Exception {
+        super.setUp();
+        route = "";
+    }
+
+    @Test
+    public void testAsyncNoWaitRouteExchange() throws Exception {
+        getMockEndpoint("mock:foo").expectedBodiesReceived("Hello World");
+        getMockEndpoint("mock:result").expectedBodiesReceived("Bye World");
+
+        // send an in out to the direct endpoint using the classic API
+        Exchange exchange = template.send(ENDPOINT_NAME, new Processor() {
+            public void process(Exchange exchange) throws Exception {
+                exchange.setPattern(ExchangePattern.InOut);
+                exchange.getIn().setBody("Hello");
+            }
+        });
+
+        route += "A";
+
+        assertMockEndpointsSatisfied();
+
+        Object out = exchange.getOut().getBody();
+        assertNotNull(out);
+
+        // camel-jetty waits for the future task to complete as it needs to stream a reply
+        // back to the http client
+        assertEquals("BA", route);
+
+        // get the response from the future
+        String response = context.getTypeConverter().convertTo(String.class, out);
+        assertEquals("Bye World", response);
+    }
+
+    @Test
+    public void testAsyncNoWaitRoute() throws Exception {
+        getMockEndpoint("mock:foo").expectedBodiesReceived("Hello World");
+        getMockEndpoint("mock:result").expectedBodiesReceived("Bye World");
+
+        // send a request reply to the direct start endpoint
+        Object out = template.requestBody(ENDPOINT_NAME, "Hello");
+
+        route += "A";
+
+        assertMockEndpointsSatisfied();
+
+        // camel-jetty waits for the future task to complete as it needs to stream a reply
+        // back to the http client
+        assertEquals("BA", route);
+
+        // get the response from the future
+        String response = context.getTypeConverter().convertTo(String.class, out);
+        assertEquals("Bye World", response);
+    }
+
+    @Test
+    public void testAsyncRouteNoWaitWithTypeConverted() throws Exception {
+        getMockEndpoint("mock:foo").expectedBodiesReceived("Hello World");
+        getMockEndpoint("mock:result").expectedBodiesReceived("Bye World");
+
+        // send a request reply to the direct start endpoint, but will use
+        // future type converter that will wait for the response, even though the async
+        // is set to not wait. As the type converter will wait for us
+        String response = template.requestBody(ENDPOINT_NAME, "Hello", String.class);
+
+        // we should wait for the async response as we ask for the result as a String body
+        route += "A";
+
+        assertMockEndpointsSatisfied();
+
+        assertEquals("Bye World", response);
+        assertEquals("BA", route);
+    }
+
+    @Override
+    protected RouteBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                // we start this route async
+                from("jetty:" + ENDPOINT_NAME)
+                            // we play a bit with the message
+                        .transform(body().append(" World"))
+                            // now turn the route into async from this point forward
+                            // the caller will have a Future<Exchange> returned as
response in OUT
+                            // to be used to grap the async response when he fell like it
+                            // we do not want to wait for tasks to be complete so we instruct
Camel
+                            // to not wait, and therefore Camel returns the Future<Exchange>
handle we
+                            // can use to get the result when we want
+                        .threads().waitForTaskToComplete(WaitForTaskToComplete.Never)
+                            // from this point forward this is the async route doing its
work
+                            // so we do a bit of delay to simulate heavy work that takes
time
+						.to("mock:foo")
+                        .delay(100)
+                            // and we also work with the message so we can prepare a response
+                        .process(new MyProcessor())
+                            // and we use mocks for unit testing
+                        .to("mock:result");
+            }
+        };
+    }
+
+    public static class MyProcessor implements Processor {
+
+        public MyProcessor() {
+        }
+
+        public void process(Exchange exchange) throws Exception {
+            route += "B";
+            assertEquals("Hello World", exchange.getIn().getBody());
+            exchange.getOut().setBody("Bye World");
+        }
+    }
+}

Propchange: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyAsyncWithThreadsTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyAsyncWithThreadsTest.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date



Mime
View raw message