You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/06/18 06:14:49 UTC
[camel] branch master updated: Fixed CS for endpointDSL example
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new df5a53f Fixed CS for endpointDSL example
df5a53f is described below
commit df5a53f939e8ac7dc240d52778fd94fc3984ffa8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Jun 18 08:14:26 2019 +0200
Fixed CS for endpointDSL example
---
.../main/java/org/apache/camel/example/cafe/CafeRouteBuilder.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/examples/camel-example-cafe-endpointdsl/src/main/java/org/apache/camel/example/cafe/CafeRouteBuilder.java b/examples/camel-example-cafe-endpointdsl/src/main/java/org/apache/camel/example/cafe/CafeRouteBuilder.java
index a7a1442..cc50ee9 100644
--- a/examples/camel-example-cafe-endpointdsl/src/main/java/org/apache/camel/example/cafe/CafeRouteBuilder.java
+++ b/examples/camel-example-cafe-endpointdsl/src/main/java/org/apache/camel/example/cafe/CafeRouteBuilder.java
@@ -20,8 +20,8 @@ import java.util.concurrent.atomic.AtomicInteger;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
-import org.apache.camel.builder.endpoint.EndpointRouteBuilder;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.builder.endpoint.EndpointRouteBuilder;
import org.apache.camel.example.cafe.stuff.Barista;
import org.apache.camel.example.cafe.stuff.CafeAggregationStrategy;
import org.apache.camel.example.cafe.stuff.DrinkRouter;
@@ -37,6 +37,8 @@ import org.apache.camel.spi.Registry;
* for Camel Endpoint DSL.
*/
public class CafeRouteBuilder extends EndpointRouteBuilder {
+
+ protected AtomicInteger orderId = new AtomicInteger();
public static void main(String[] args) throws Exception {
CafeRouteBuilder builder = new CafeRouteBuilder();
@@ -80,8 +82,6 @@ public class CafeRouteBuilder extends EndpointRouteBuilder {
camelContext.stop();
}
- protected AtomicInteger orderId = new AtomicInteger();
-
protected void newOrder(Exchange exchange) {
Order order = new Order(orderId.incrementAndGet());
order.addItem(DrinkType.ESPRESSO, 2, true);