Merge pull request #5 from akoufoudakis/FIX_EXAMPLES_WITH_MAIN
Fixed examples camel main class
diff --git a/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/ArtemisMain.java b/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/ArtemisMain.java
index 044136e..f32d9bd 100644
--- a/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/ArtemisMain.java
+++ b/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/ArtemisMain.java
@@ -38,10 +38,10 @@
main.bind("artemis", createArtemisComponent());
// add the widget/gadget route
- main.addRoutesBuilder(new WidgetGadgetRoute());
+ main.configure().addRoutesBuilder(new WidgetGadgetRoute());
// add a 2nd route that routes files from src/data to the order queue
- main.addRoutesBuilder(new CreateOrderRoute());
+ main.configure().addRoutesBuilder(new CreateOrderRoute());
// start and run Camel (block)
main.run();
diff --git a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java
index 019930d..841bad7 100644
--- a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java
+++ b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java
@@ -46,7 +46,7 @@
LOG.debug("About to run Debezium integration...");
// add route
- main.addRoutesBuilder(new RouteBuilder() {
+ main.configure().addRoutesBuilder(new RouteBuilder() {
public void configure() {
// Initial Debezium route that will run and listens to the changes,
// first it will perform an initial snapshot using (select * from) in case there are no offsets
diff --git a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/KinesisProducerToCassandra.java b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/KinesisProducerToCassandra.java
index 72dda9f..e4094ad 100644
--- a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/KinesisProducerToCassandra.java
+++ b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/KinesisProducerToCassandra.java
@@ -44,7 +44,7 @@
LOG.debug("About to run Kinesis to Cassandra integration...");
// add route
- main.addRoutesBuilder(new RouteBuilder() {
+ main.configure().addRoutesBuilder(new RouteBuilder() {
public void configure() {
// We set the CQL templates we need, note that an UPDATE in Cassandra means an UPSERT which is what we need
final String cqlUpdate = "update products set name = ?, description = ?, weight = ? where id = ?";
diff --git a/examples/camel-example-ftp/src/main/java/org/apache/camel/example/ftp/MyFtpClient.java b/examples/camel-example-ftp/src/main/java/org/apache/camel/example/ftp/MyFtpClient.java
index dd7a314..3dc3eca 100644
--- a/examples/camel-example-ftp/src/main/java/org/apache/camel/example/ftp/MyFtpClient.java
+++ b/examples/camel-example-ftp/src/main/java/org/apache/camel/example/ftp/MyFtpClient.java
@@ -28,7 +28,7 @@
public static void main(String[] args) throws Exception {
Main main = new Main();
- main.addRoutesBuilder(new MyFtpClientRouteBuilder());
+ main.configure().addRoutesBuilder(new MyFtpClientRouteBuilder());
main.run();
}
diff --git a/examples/camel-example-ftp/src/main/java/org/apache/camel/example/ftp/MyFtpServer.java b/examples/camel-example-ftp/src/main/java/org/apache/camel/example/ftp/MyFtpServer.java
index d901636..dd9600c 100644
--- a/examples/camel-example-ftp/src/main/java/org/apache/camel/example/ftp/MyFtpServer.java
+++ b/examples/camel-example-ftp/src/main/java/org/apache/camel/example/ftp/MyFtpServer.java
@@ -28,7 +28,7 @@
public static void main(String[] args) throws Exception {
Main main = new Main();
- main.addRoutesBuilder(new MyFtpServerRouteBuilder());
+ main.configure().addRoutesBuilder(new MyFtpServerRouteBuilder());
main.run();
}
diff --git a/examples/camel-example-java8/src/main/java/org/apache/camel/example/java8/MyApplication.java b/examples/camel-example-java8/src/main/java/org/apache/camel/example/java8/MyApplication.java
index 2dddb3f..86c9c4f 100644
--- a/examples/camel-example-java8/src/main/java/org/apache/camel/example/java8/MyApplication.java
+++ b/examples/camel-example-java8/src/main/java/org/apache/camel/example/java8/MyApplication.java
@@ -34,7 +34,7 @@
public static void main(String[] args) throws Exception {
Main main = new Main();
- main.addRoutesBuilder(new MyRouteBuilder());
+ main.configure().addRoutesBuilder(new MyRouteBuilder());
main.run(args);
}
diff --git a/examples/camel-example-kotlin/src/main/kotlin/org/apache/camel/example/MainApp.kt b/examples/camel-example-kotlin/src/main/kotlin/org/apache/camel/example/MainApp.kt
index 07359ff..c2d3e26 100644
--- a/examples/camel-example-kotlin/src/main/kotlin/org/apache/camel/example/MainApp.kt
+++ b/examples/camel-example-kotlin/src/main/kotlin/org/apache/camel/example/MainApp.kt
@@ -30,6 +30,6 @@
System.out.println("\n\n\n\n");
val main = Main()
- main.addRoutesBuilder(MyRouteBuilder())
+ main.configure().addRoutesBuilder(MyRouteBuilder())
main.run(args)
}
diff --git a/examples/camel-example-loan-broker-jms/src/main/java/org/apache/camel/loanbroker/LoanBroker.java b/examples/camel-example-loan-broker-jms/src/main/java/org/apache/camel/loanbroker/LoanBroker.java
index 5deeb53..40ce2fb 100644
--- a/examples/camel-example-loan-broker-jms/src/main/java/org/apache/camel/loanbroker/LoanBroker.java
+++ b/examples/camel-example-loan-broker-jms/src/main/java/org/apache/camel/loanbroker/LoanBroker.java
@@ -33,7 +33,7 @@
// configure the location of the Spring XML file
main.setApplicationContextUri("META-INF/spring/server.xml");
- main.addRoutesBuilder(new LoanBrokerRoute());
+ main.configure().addRoutesBuilder(new LoanBrokerRoute());
main.run();
}
diff --git a/examples/camel-example-main-artemis/src/main/java/org/apache/camel/example/MyApplication.java b/examples/camel-example-main-artemis/src/main/java/org/apache/camel/example/MyApplication.java
index c6214d0..b6dce99 100644
--- a/examples/camel-example-main-artemis/src/main/java/org/apache/camel/example/MyApplication.java
+++ b/examples/camel-example-main-artemis/src/main/java/org/apache/camel/example/MyApplication.java
@@ -31,9 +31,9 @@
Main main = new Main();
// lets use a configuration class (you can specify multiple classes)
// (properties are automatic loaded from application.properties)
- main.addConfigurationClass(MyConfiguration.class);
+ main.configure().addConfigurationClass(MyConfiguration.class);
// and add the routes (you can specify multiple classes)
- main.addRouteBuilder(MyRouteBuilder.class);
+ main.configure().addRoutesBuilder(MyRouteBuilder.class);
// now keep the application running until the JVM is terminated (ctrl + c or sigterm)
main.run(args);
}
diff --git a/examples/camel-example-main-tiny/src/main/java/org/apache/camel/example/MyApplication.java b/examples/camel-example-main-tiny/src/main/java/org/apache/camel/example/MyApplication.java
index 8c1cc6a..496b37d 100644
--- a/examples/camel-example-main-tiny/src/main/java/org/apache/camel/example/MyApplication.java
+++ b/examples/camel-example-main-tiny/src/main/java/org/apache/camel/example/MyApplication.java
@@ -30,7 +30,7 @@
// use Camels Main class
Main main = new Main();
// and add the routes (you can specify multiple classes)
- main.addRouteBuilder(MyRouteBuilder.class);
+ main.configure().addRoutesBuilder(MyRouteBuilder.class);
// now keep the application running until the JVM is terminated (ctrl + c or sigterm)
main.run(args);
}
diff --git a/examples/camel-example-main-xml/src/main/java/org/apache/camel/example/MyApplication.java b/examples/camel-example-main-xml/src/main/java/org/apache/camel/example/MyApplication.java
index f0573fd..9c6b59b 100644
--- a/examples/camel-example-main-xml/src/main/java/org/apache/camel/example/MyApplication.java
+++ b/examples/camel-example-main-xml/src/main/java/org/apache/camel/example/MyApplication.java
@@ -31,7 +31,7 @@
Main main = new Main();
// lets use a configuration class (you can specify multiple classes)
// (properties are automatic loaded from application.properties)
- main.addConfigurationClass(MyConfiguration.class);
+ main.configure().addConfigurationClass(MyConfiguration.class);
// and add all the XML routes
main.configure().withXmlRoutes("routes/*.xml");
diff --git a/examples/camel-example-main/src/main/java/org/apache/camel/example/MyApplication.java b/examples/camel-example-main/src/main/java/org/apache/camel/example/MyApplication.java
index c6214d0..b6dce99 100644
--- a/examples/camel-example-main/src/main/java/org/apache/camel/example/MyApplication.java
+++ b/examples/camel-example-main/src/main/java/org/apache/camel/example/MyApplication.java
@@ -31,9 +31,9 @@
Main main = new Main();
// lets use a configuration class (you can specify multiple classes)
// (properties are automatic loaded from application.properties)
- main.addConfigurationClass(MyConfiguration.class);
+ main.configure().addConfigurationClass(MyConfiguration.class);
// and add the routes (you can specify multiple classes)
- main.addRouteBuilder(MyRouteBuilder.class);
+ main.configure().addRoutesBuilder(MyRouteBuilder.class);
// now keep the application running until the JVM is terminated (ctrl + c or sigterm)
main.run(args);
}
diff --git a/examples/camel-example-mongodb/src/main/java/org/apache/camel/example/mongodb/Application.java b/examples/camel-example-mongodb/src/main/java/org/apache/camel/example/mongodb/Application.java
index 4983c21..f56da3e 100644
--- a/examples/camel-example-mongodb/src/main/java/org/apache/camel/example/mongodb/Application.java
+++ b/examples/camel-example-mongodb/src/main/java/org/apache/camel/example/mongodb/Application.java
@@ -37,9 +37,9 @@
main = new Main();
// bind connectionBean used by the component
main.bind("myDb", MongoClients.create("mongodb://localhost"));
- main.addRoutesBuilder(new MongoDBFindByIDRouteBuilder());
- main.addRoutesBuilder(new MongoDBFindAllRouteBuilder());
- main.addRoutesBuilder(new MongoDBInsertRouteBuilder());
+ main.configure().addRoutesBuilder(new MongoDBFindByIDRouteBuilder());
+ main.configure().addRoutesBuilder(new MongoDBFindAllRouteBuilder());
+ main.configure().addRoutesBuilder(new MongoDBInsertRouteBuilder());
System.out.println("Starting Camel. Use CTRL + C to terminate the process.\n");
main.run();
}
diff --git a/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyClient.java b/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyClient.java
index a26ca4c..6cd4ba0 100644
--- a/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyClient.java
+++ b/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyClient.java
@@ -33,7 +33,7 @@
public static void main(String[] args) throws Exception {
Main main = new Main();
- main.addRoutesBuilder(new MyRouteBuilder());
+ main.configure().addRoutesBuilder(new MyRouteBuilder());
// setup correlation manager and its timeout (when a request has not received a response within the given time millis)
MyCorrelationManager manager = new MyCorrelationManager();
diff --git a/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyServer.java b/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyServer.java
index b7f9826..e198d07 100644
--- a/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyServer.java
+++ b/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyServer.java
@@ -29,7 +29,7 @@
public static void main(String[] args) throws Exception {
Main main = new Main();
- main.addRoutesBuilder(new MyRouteBuilder());
+ main.configure().addRoutesBuilder(new MyRouteBuilder());
main.bind("myEncoder", new MyCodecEncoderFactory());
main.bind("myDecoder", new MyCodecDecoderFactory());
main.run(args);
diff --git a/examples/camel-example-reactive-executor-vertx/src/main/java/org/apache/camel/example/MyApplication.java b/examples/camel-example-reactive-executor-vertx/src/main/java/org/apache/camel/example/MyApplication.java
index 8c1cc6a..496b37d 100644
--- a/examples/camel-example-reactive-executor-vertx/src/main/java/org/apache/camel/example/MyApplication.java
+++ b/examples/camel-example-reactive-executor-vertx/src/main/java/org/apache/camel/example/MyApplication.java
@@ -30,7 +30,7 @@
// use Camels Main class
Main main = new Main();
// and add the routes (you can specify multiple classes)
- main.addRouteBuilder(MyRouteBuilder.class);
+ main.configure().addRoutesBuilder(MyRouteBuilder.class);
// now keep the application running until the JVM is terminated (ctrl + c or sigterm)
main.run(args);
}
diff --git a/examples/camel-example-splunk/src/main/java/org/apache/camel/example/splunk/SplunkSavedSearchClient.java b/examples/camel-example-splunk/src/main/java/org/apache/camel/example/splunk/SplunkSavedSearchClient.java
index d8232d7..a89f649 100644
--- a/examples/camel-example-splunk/src/main/java/org/apache/camel/example/splunk/SplunkSavedSearchClient.java
+++ b/examples/camel-example-splunk/src/main/java/org/apache/camel/example/splunk/SplunkSavedSearchClient.java
@@ -30,7 +30,7 @@
public static void main(String[] args) throws Exception {
LOG.info("About to run splunk-camel integration...");
Main main = new Main();
- main.addRoutesBuilder(new SplunkSavedSearchRouteBuilder());
+ main.configure().addRoutesBuilder(new SplunkSavedSearchRouteBuilder());
main.run();
}
}
diff --git a/examples/camel-example-splunk/src/main/java/org/apache/camel/example/splunk/SplunkSearchClient.java b/examples/camel-example-splunk/src/main/java/org/apache/camel/example/splunk/SplunkSearchClient.java
index 5fca8fa..ad0961a 100644
--- a/examples/camel-example-splunk/src/main/java/org/apache/camel/example/splunk/SplunkSearchClient.java
+++ b/examples/camel-example-splunk/src/main/java/org/apache/camel/example/splunk/SplunkSearchClient.java
@@ -30,7 +30,7 @@
public static void main(String[] args) throws Exception {
LOG.info("About to run splunk-camel integration...");
Main main = new Main();
- main.addRoutesBuilder(new SplunkSearchRouteBuilder());
+ main.configure().addRoutesBuilder(new SplunkSearchRouteBuilder());
main.run();
}
diff --git a/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java b/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
index df8dc32..e651dfa 100644
--- a/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
+++ b/examples/camel-example-twitter-websocket/src/main/java/org/apache/camel/example/websocket/CamelTwitterWebSocketMain.java
@@ -68,7 +68,7 @@
route.setPort(9090);
// add our routes to Camel
- main.addRoutesBuilder(route);
+ main.configure().addRoutesBuilder(route);
// and run, which keeps blocking until we terminate the JVM (or stop CamelContext)
main.run();
diff --git a/examples/camel-example-widget-gadget-java/src/main/java/org/apache/camel/example/widget/WidgetMain.java b/examples/camel-example-widget-gadget-java/src/main/java/org/apache/camel/example/widget/WidgetMain.java
index dafff5b..7870424 100644
--- a/examples/camel-example-widget-gadget-java/src/main/java/org/apache/camel/example/widget/WidgetMain.java
+++ b/examples/camel-example-widget-gadget-java/src/main/java/org/apache/camel/example/widget/WidgetMain.java
@@ -36,10 +36,10 @@
main.bind("activemq", createActiveMQComponent());
// add the widget/gadget route
- main.addRoutesBuilder(new WidgetGadgetRoute());
+ main.configure().addRoutesBuilder(new WidgetGadgetRoute());
// add a 2nd route that routes files from src/main/data to the order queue
- main.addRoutesBuilder(new CreateOrderRoute());
+ main.configure().addRoutesBuilder(new CreateOrderRoute());
// start and run Camel (block)
main.run();
