Return-Path: Delivered-To: apmail-camel-commits-archive@www.apache.org Received: (qmail 78206 invoked from network); 4 Feb 2009 19:20:00 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 4 Feb 2009 19:20:00 -0000 Received: (qmail 52202 invoked by uid 500); 4 Feb 2009 19:20:00 -0000 Delivered-To: apmail-camel-commits-archive@camel.apache.org Received: (qmail 52182 invoked by uid 500); 4 Feb 2009 19:20:00 -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 52173 invoked by uid 99); 4 Feb 2009 19:20:00 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 04 Feb 2009 11:20:00 -0800 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; Wed, 04 Feb 2009 19:19:59 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id D126C238896B; Wed, 4 Feb 2009 19:19:38 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r740836 - /camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ComposedMessageProcessorTest.java Date: Wed, 04 Feb 2009 19:19:38 -0000 To: commits@camel.apache.org From: janstey@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090204191938.D126C238896B@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: janstey Date: Wed Feb 4 19:19:38 2009 New Revision: 740836 URL: http://svn.apache.org/viewvc?rev=740836&view=rev Log: CAMEL-1315 - Add some wiki snippets Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ComposedMessageProcessorTest.java Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ComposedMessageProcessorTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ComposedMessageProcessorTest.java?rev=740836&r1=740835&r2=740836&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ComposedMessageProcessorTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ComposedMessageProcessorTest.java Wed Feb 4 19:19:38 2009 @@ -54,13 +54,15 @@ MockEndpoint resultEndpoint = getMockEndpoint("mock:result"); resultEndpoint.expectedMessageCount(1); resultEndpoint.expectedHeaderReceived("orderId", "myorderid"); - + + // START SNIPPET: e1 List order = Arrays.asList(new OrderItem[] { new OrderItem("widget", 500), new OrderItem("gadget", 200)}); template.sendBodyAndHeader("direct:start", order, "orderId", "myorderid"); - + // END SNIPPET: e1 + assertMockEndpointsSatisfied(); List validatedOrder = resultEndpoint.getExchanges().get(0).getIn().getBody(List.class); @@ -79,6 +81,7 @@ protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { + // START SNIPPET: e2 // split up the order so individual OrderItems can be validated by the appropriate bean from("direct:start").split().body().choice() .when().method("orderItemHelper", "isWidget").to("bean:widgetInventory", "seda:aggregate") @@ -86,10 +89,12 @@ // collect and re-assemble the validated OrderItems into an order again from("seda:aggregate").aggregate(new MyOrderAggregationStrategy()).header("orderId").to("mock:result"); + // END SNIPPET: e2 } }; } + // START SNIPPET: e3 public static final class OrderItem { String type; // type of the item int quantity; // how many we want @@ -100,19 +105,23 @@ this.quantity = quantity; } } + // END SNIPPET: e3 public static final class OrderItemHelper { private OrderItemHelper() { } + // START SNIPPET: e4 public static boolean isWidget(@Body OrderItem orderItem) { return orderItem.type.equals("widget"); } + // END SNIPPET: e4 } /** * Bean that checks whether the specified number of widgets can be ordered */ + // START SNIPPET: e5 public static final class WidgetInventory { public void checkInventory(@Body OrderItem orderItem) { assertEquals("widget", orderItem.type); @@ -121,10 +130,12 @@ } } } + // END SNIPPET: e5 /** * Bean that checks whether the specified number of gadgets can be ordered */ + // START SNIPPET: e6 public static final class GadgetInventory { public void checkInventory(@Body OrderItem orderItem) { assertEquals("gadget", orderItem.type); @@ -133,11 +144,13 @@ } } } + // END SNIPPET: e6 /** * Aggregation strategy that re-assembles the validated OrderItems * into an order, which is just a List. */ + // START SNIPPET: e7 public static final class MyOrderAggregationStrategy implements AggregationStrategy { public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { List order = new ArrayList(2); @@ -147,4 +160,5 @@ return oldExchange; } } + // END SNIPPET: e7 }