camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nferr...@apache.org
Subject [1/2] camel git commit: CAMEL-10612: spring-boot binding and example (style fix)
Date Tue, 31 Jan 2017 16:13:46 GMT
Repository: camel
Updated Branches:
  refs/heads/master c01faa499 -> c76224c1a


CAMEL-10612: spring-boot binding and example (style fix)


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c76224c1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c76224c1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c76224c1

Branch: refs/heads/master
Commit: c76224c1a178ae28ead18c2052a67302a020478c
Parents: 47f44ce
Author: Nicola Ferraro <ni.ferraro@gmail.com>
Authored: Tue Jan 31 17:13:13 2017 +0100
Committer: Nicola Ferraro <ni.ferraro@gmail.com>
Committed: Tue Jan 31 17:13:23 2017 +0100

----------------------------------------------------------------------
 .../streams/ReactiveStreamsSpringBootApp.java     |  2 ++
 .../reactive/streams/SampleCamelRoutes.java       |  8 ++++----
 .../reactive/streams/SampleReactiveStreams.java   | 18 +++++++++++++++++-
 3 files changed, 23 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/c76224c1/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/ReactiveStreamsSpringBootApp.java
----------------------------------------------------------------------
diff --git a/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/ReactiveStreamsSpringBootApp.java
b/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/ReactiveStreamsSpringBootApp.java
index f16031a..6440d6b 100644
--- a/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/ReactiveStreamsSpringBootApp.java
+++ b/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/ReactiveStreamsSpringBootApp.java
@@ -19,6 +19,7 @@ package org.apache.camel.example.reactive.streams;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
+//CHECKSTYLE:OFF
 @SpringBootApplication
 public class ReactiveStreamsSpringBootApp {
 
@@ -27,3 +28,4 @@ public class ReactiveStreamsSpringBootApp {
     }
 
 }
+//CHECKSTYLE:ON

http://git-wip-us.apache.org/repos/asf/camel/blob/c76224c1/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleCamelRoutes.java
----------------------------------------------------------------------
diff --git a/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleCamelRoutes.java
b/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleCamelRoutes.java
index 9894395..cc5b59b 100644
--- a/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleCamelRoutes.java
+++ b/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleCamelRoutes.java
@@ -28,13 +28,13 @@ public class SampleCamelRoutes extends RouteBuilder {
 
         // Generating numbers every 3 seconds and forwarding to the stream "numbers"
         from("timer:clock?period=3000")
-        .setBody().header(Exchange.TIMER_COUNTER)
-        .to("reactive-streams:numbers");
+                .setBody().header(Exchange.TIMER_COUNTER)
+                .to("reactive-streams:numbers");
 
         // Generating strings every 2.9 seconds and forwarding to the stream "strings"
         from("timer:clock2?period=2900&delay=1000")
-        .setBody().simple("Hello World ${header.CamelTimerCounter}!")
-        .to("reactive-streams:strings");
+                .setBody().simple("Hello World ${header.CamelTimerCounter}!")
+                .to("reactive-streams:strings");
 
     }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/c76224c1/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleReactiveStreams.java
----------------------------------------------------------------------
diff --git a/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleReactiveStreams.java
b/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleReactiveStreams.java
index a9dab1b..271e209 100644
--- a/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleReactiveStreams.java
+++ b/examples/camel-example-reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/SampleReactiveStreams.java
@@ -1,3 +1,19 @@
+/**
+ * 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.example.reactive.streams;
 
 import javax.annotation.PostConstruct;
@@ -14,7 +30,7 @@ import reactor.core.publisher.Flux;
 @Component
 public class SampleReactiveStreams {
 
-    private static Logger LOG = LoggerFactory.getLogger(SampleReactiveStreams.class);
+    private static final Logger LOG = LoggerFactory.getLogger(SampleReactiveStreams.class);
 
     @Autowired
     private CamelReactiveStreamsService camelStreams;


Mime
View raw message