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 2016/11/25 12:17:24 UTC
[01/28] camel git commit: Revert "Camel-Firebase: Full build of Camel
with the new component"
Repository: camel
Updated Branches:
refs/heads/master 83e97655c -> e234e4fdf
Revert "Camel-Firebase: Full build of Camel with the new component"
This reverts commit 4e7a7ce11d8cdc6560bb7bfd3a7ccfb53b6deda3.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/200226af
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/200226af
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/200226af
Branch: refs/heads/master
Commit: 200226af342e3a2b69bbf24f969df00da95105b2
Parents: 83e9765
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:20 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:20 2016 +0100
----------------------------------------------------------------------
apache-camel/pom.xml | 5 -----
components/readme.adoc | 3 ---
docs/user-manual/en/SUMMARY.md | 1 -
.../spring-boot-dm/camel-spring-boot-dependencies/pom.xml | 5 -----
4 files changed, 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/200226af/apache-camel/pom.xml
----------------------------------------------------------------------
diff --git a/apache-camel/pom.xml b/apache-camel/pom.xml
index fea8b5e..72894cf 100644
--- a/apache-camel/pom.xml
+++ b/apache-camel/pom.xml
@@ -1269,11 +1269,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-firebase-starter</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-flatpack-starter</artifactId>
<version>${project.version}</version>
</dependency>
http://git-wip-us.apache.org/repos/asf/camel/blob/200226af/components/readme.adoc
----------------------------------------------------------------------
diff --git a/components/readme.adoc b/components/readme.adoc
index 4df0174..dbbc3ff 100644
--- a/components/readme.adoc
+++ b/components/readme.adoc
@@ -168,9 +168,6 @@ Components
| link:camel-facebook/src/main/docs/facebook-component.adoc[Facebook] (camel-facebook) +
`facebook:methodName` | The Facebook component provides access to all of the Facebook APIs accessible using Facebook4J.
-| link:camel-firebase/src/main/docs/firebase-component.adoc[Firebase] (camel-firebase) +
-`firebase:databaseUrl` | The Google Firebasecomponent enables you to save and modify data in a Google Firebase database via the FirebaseProducer class.
-
| link:camel-flatpack/src/main/docs/flatpack-component.adoc[Flatpack] (camel-flatpack) +
`flatpack:type:resourceUri` | The flatpack component supports fixed width and delimited file parsing via the FlatPack library.
http://git-wip-us.apache.org/repos/asf/camel/blob/200226af/docs/user-manual/en/SUMMARY.md
----------------------------------------------------------------------
diff --git a/docs/user-manual/en/SUMMARY.md b/docs/user-manual/en/SUMMARY.md
index 6aece7c..8efc73c 100644
--- a/docs/user-manual/en/SUMMARY.md
+++ b/docs/user-manual/en/SUMMARY.md
@@ -198,7 +198,6 @@
* [etcd](etcd-component.adoc)
* [Exec](exec-component.adoc)
* [Facebook](facebook-component.adoc)
- * [Firebase](firebase-component.adoc)
* [Flatpack](flatpack-component.adoc)
* [FOP](fop-component.adoc)
* [Freemarker](freemarker-component.adoc)
http://git-wip-us.apache.org/repos/asf/camel/blob/200226af/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml b/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
index 5a17daa..d23ed18 100644
--- a/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
+++ b/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
@@ -794,11 +794,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-firebase</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-flatpack</artifactId>
<version>${project.version}</version>
</dependency>
[18/28] camel git commit: Revert "Moved Firebase version to parent
pom.xml"
Posted by ac...@apache.org.
Revert "Moved Firebase version to parent pom.xml"
This reverts commit e5f6b42da0318d55f153fb675c8f5c045cacee28.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/66870050
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/66870050
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/66870050
Branch: refs/heads/master
Commit: 6687005080dbdb0bef898ee09b590737cff4bf67
Parents: bf43663
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:10 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:10 2016 +0100
----------------------------------------------------------------------
components/camel-firebase/pom.xml | 1 +
parent/pom.xml | 1 -
2 files changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/66870050/components/camel-firebase/pom.xml
----------------------------------------------------------------------
diff --git a/components/camel-firebase/pom.xml b/components/camel-firebase/pom.xml
index 9521fb9..e444bed 100644
--- a/components/camel-firebase/pom.xml
+++ b/components/camel-firebase/pom.xml
@@ -16,6 +16,7 @@
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+ <firebase.version>4.0.1</firebase.version>
<maven.test.skip>true</maven.test.skip>
</properties>
http://git-wip-us.apache.org/repos/asf/camel/blob/66870050/parent/pom.xml
----------------------------------------------------------------------
diff --git a/parent/pom.xml b/parent/pom.xml
index aa4103d..95bd673 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -191,7 +191,6 @@
<felix-framework-version>3.2.2</felix-framework-version>
<felix-scr-annotations-version>1.9.12</felix-scr-annotations-version>
<findbugs-maven-plugin-version>2.5.2</findbugs-maven-plugin-version>
- <firebase.version>4.0.1</firebase.version>
<flatpack-version>3.4.3</flatpack-version>
<flink-version>1.1.3</flink-version>
<fop-bundle-version>2.1_1</fop-bundle-version>
[14/28] camel git commit: Revert "Removed toString method."
Posted by ac...@apache.org.
Revert "Removed toString method."
This reverts commit 7cf73e0c5385aa93debd17ec36429bdcb542059a.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7530f41d
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7530f41d
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7530f41d
Branch: refs/heads/master
Commit: 7530f41ddf3c6f4e4b9ba3d6c5794db5e3cbcfae
Parents: a581c4e
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:00 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:00 2016 +0100
----------------------------------------------------------------------
.../camel/component/firebase/data/FirebaseMessage.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/7530f41d/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
index 5edb2eb..4999102 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
@@ -55,6 +55,15 @@ public final class FirebaseMessage {
return databaseError;
}
+ @Override
+ public String toString() {
+ return "FirebaseMessage{"
+ + "operation=" + operation
+ + ", dataSnapshot=" + dataSnapshot
+ + ", previousChildName='" + previousChildName + '\''
+ + ", databaseError=" + databaseError + '}';
+ }
+
public static class Builder {
private final Operation operation;
[08/28] camel git commit: Revert "Copied the license text from the
Apache Flink component."
Posted by ac...@apache.org.
Revert "Copied the license text from the Apache Flink component."
This reverts commit a3bf745ec9f5c3352a8c58a1e40e8d131c36ff27.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/905b87c4
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/905b87c4
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/905b87c4
Branch: refs/heads/master
Commit: 905b87c45c7610c5c83f8ee2d7a457c861629bce
Parents: f3f9575
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:46 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:46 2016 +0100
----------------------------------------------------------------------
.../camel-firebase/src/main/resources/META-INF/LICENSE.txt | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/905b87c4/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt b/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt
index 7a4a3ea..5861116 100644
--- a/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt
+++ b/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt
@@ -187,7 +187,7 @@
same "printed page" as the copyright notice for easier
identification within third-party archives.
- Copyright [yyyy] [name of copyright owner]
+ Copyright 2016 Onepoint Ltd
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
@@ -199,4 +199,5 @@
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.
\ No newline at end of file
+ limitations under the License.
+
[10/28] camel git commit: Revert "Changed the version in which the
component is going to be available."
Posted by ac...@apache.org.
Revert "Changed the version in which the component is going to be available."
This reverts commit e2c4b132353d7d1603149b1be77d36472e7f103f.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/93291ece
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/93291ece
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/93291ece
Branch: refs/heads/master
Commit: 93291ece6382f92c78979d2e5af06d4d524876f3
Parents: 24fe56b
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:51 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:51 2016 +0100
----------------------------------------------------------------------
.../camel-firebase/src/main/docs/firebase-component.adoc | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/93291ece/components/camel-firebase/src/main/docs/firebase-component.adoc
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/docs/firebase-component.adoc b/components/camel-firebase/src/main/docs/firebase-component.adoc
index 4d6837a..c0701cf 100644
--- a/components/camel-firebase/src/main/docs/firebase-component.adoc
+++ b/components/camel-firebase/src/main/docs/firebase-component.adoc
@@ -2,7 +2,7 @@
Firebase Component
~~~~~~~~~~~~~~~~~
-*Available as of Camel 2.19*
+*Available as of Camel 2.19.x*
The *firebase*�component enables you to save, modify data in Google Firebase database
and consume to all child of a specific reference.
@@ -46,13 +46,11 @@ Options
// endpoint options: START
The Firebase component supports 9 endpoint options which are listed below:
-{% raw %}
[width="100%",cols="2,1,1m,1m,5",options="header"]
|=======================================================================
| Name | Group | Default | Java Type | Description
-| databaseUrl | common | | String | *Required* The Firebase database URL. Always uses https
| keyName | common | firebaseKey | String | The Camel exchange header name in which the Firebase key is specified. Only needed in case you are saving or updating data
-| reply | common | reply | boolean | If true the save or update request (set value in Firebase terms) is fired and the reply will be ignored else the routing thread will wait and the reply will be saved in the exchange message
+| reply | common | false | boolean | If *false* the save or update request (*setValue* in Firebase terms) is fired and the reply will be ignored, otherwise the routing thread will wait and the reply will be saved in the body of the exchange message
| rootReference | common | | String | *Required* The path in the database tree where the key value pairs are to be stored
| serviceAccountFile | common | | String | *Required* The path to the JSON file which provided the keys used to connect to Firebase. This file is typically generated when you create the database
| bridgeErrorHandler | consumer | false | boolean | Allows for bridging the consumer to the Camel routing Error Handler which mean any exceptions occurred while the consumer is trying to pickup incoming messages or the likes will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions that will be logged at WARN/ERROR level and ignored.
@@ -60,7 +58,6 @@ The Firebase component supports 9 endpoint options which are listed below:
| exchangePattern | consumer (advanced) | | ExchangePattern | Sets the exchange pattern when the consumer creates an exchange.
| synchronous | advanced | false | boolean | Sets whether synchronous processing should be strictly used or Camel is allowed to use asynchronous processing (if supported).
|=======================================================================
-{% endraw %}
// endpoint options: END
@@ -162,4 +159,4 @@ See Also
* link:endpoint.html[Endpoint]
* link:getting-started.html[Getting Started]
* link:https://firebase.google.com/[Firebase]
-* link:https://console.firebase.google.com/[Firebase console]
+* link:https://console.firebase.google.com/[Firebase console]
\ No newline at end of file
[28/28] camel git commit: Camel-Firebase: removed component
Posted by ac...@apache.org.
Camel-Firebase: removed component
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e234e4fd
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e234e4fd
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e234e4fd
Branch: refs/heads/master
Commit: e234e4fdf1488624cbe68661315d996eb89db26e
Parents: 520160f
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:51:48 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:51:48 2016 +0100
----------------------------------------------------------------------
components/camel-firebase/pom.xml | 65 ------
.../component/firebase/FirebaseComponent.java | 37 ----
.../component/firebase/FirebaseConfig.java | 103 ----------
.../component/firebase/FirebaseConsumer.java | 82 --------
.../component/firebase/FirebaseEndpoint.java | 97 ---------
.../component/firebase/FirebaseProducer.java | 61 ------
.../firebase/data/FirebaseMessage.java | 88 --------
.../component/firebase/data/Operation.java | 13 --
.../exception/DatabaseErrorException.java | 16 --
.../firebase/exception/FirebaseException.java | 57 ------
.../src/main/resources/META-INF/LICENSE.txt | 203 -------------------
.../org/apache/camel/component/firebase | 1 -
.../firebase/FirebaseConsumerDeleteTest.java | 87 --------
.../firebase/FirebaseConsumerTest.java | 77 -------
.../firebase/FirebaseProducerTest.java | 91 ---------
.../provider/ConfigurationProvider.java | 41 ----
.../firebase/provider/SampleInputProvider.java | 44 ----
...-app-firebase-adminsdk-rcwg7-fea519a672.json | 12 --
.../src/test/resources/log4j2.properties | 7 -
.../src/test/resources/sample_message.txt | 1 -
20 files changed, 1183 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/pom.xml
----------------------------------------------------------------------
diff --git a/components/camel-firebase/pom.xml b/components/camel-firebase/pom.xml
deleted file mode 100644
index ad76990..0000000
--- a/components/camel-firebase/pom.xml
+++ /dev/null
@@ -1,65 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- <parent>
- <artifactId>components</artifactId>
- <groupId>org.apache.camel</groupId>
- <version>2.19.0-SNAPSHOT</version>
- </parent>
- <modelVersion>4.0.0</modelVersion>
-
- <name>Camel :: Firebase</name>
-
- <artifactId>camel-firebase</artifactId>
-
- <properties>
- <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
- <firebase.version>4.0.1</firebase.version>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-core</artifactId>
- </dependency>
- <!-- compile 'com.google.firebase:firebase-database:9.8.0' -->
- <dependency>
- <groupId>com.google.firebase</groupId>
- <artifactId>firebase-admin</artifactId>
- <version>${firebase.version}</version>
- </dependency>
-
- <!-- testing -->
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-api</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-core</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-slf4j-impl</artifactId>
- <scope>test</scope>
- </dependency>
-
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test</artifactId>
- <scope>test</scope>
- </dependency>
- <!-- https://mvnrepository.com/artifact/org.assertj/assertj-core -->
- <dependency>
- <groupId>org.assertj</groupId>
- <artifactId>assertj-core</artifactId>
- <version>3.5.2</version>
- <scope>test</scope>
- </dependency>
- </dependencies>
-
-</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
deleted file mode 100644
index 18e6d64..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
+++ /dev/null
@@ -1,37 +0,0 @@
-package org.apache.camel.component.firebase;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.Endpoint;
-import org.apache.camel.impl.UriEndpointComponent;
-
-import java.util.Map;
-
-/**
- * Represents the component that manages {@link FirebaseEndpoint}.
- */
-public class FirebaseComponent extends UriEndpointComponent {
-
- public FirebaseComponent() {
- super(FirebaseEndpoint.class);
- }
-
- public FirebaseComponent(CamelContext context) {
- super(context, FirebaseEndpoint.class);
- }
-
- protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
-
- FirebaseConfig firebaseConfig = new FirebaseConfig.Builder(
- String.format("https://%s", remaining),
- (String) parameters.get("rootReference"),
- (String) parameters.get("serviceAccountFile"))
- .build();
-
- firebaseConfig.init();
-
- Endpoint endpoint = new FirebaseEndpoint(uri, this, firebaseConfig);
- setProperties(endpoint, parameters);
- return endpoint;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java
deleted file mode 100644
index a46caf8..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java
+++ /dev/null
@@ -1,103 +0,0 @@
-package org.apache.camel.component.firebase;
-
-import com.google.firebase.FirebaseApp;
-import com.google.firebase.FirebaseOptions;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.util.UUID;
-
-/**
- * Contains the elements needed to connect to Firebase
- */
-public class FirebaseConfig {
-
- private final String databaseUrl;
-
- private final String rootReference;
-
- private final String serviceAccountFile;
-
- private final String keyName;
-
- private final boolean async;
-
- private FirebaseApp firebaseApp;
-
- private FirebaseConfig(Builder builder) {
- this.databaseUrl = builder.databaseUrl;
- this.rootReference = builder.rootReference;
- this.serviceAccountFile = builder.serviceAccountFile;
- this.keyName = builder.keyName;
- this.async = builder.async;
- }
-
- public void init() throws IOException {
- try(InputStream in = Files.newInputStream(Paths.get(serviceAccountFile))) {
- FirebaseOptions options = new FirebaseOptions.Builder()
- .setServiceAccount(in)
- .setDatabaseUrl(this.databaseUrl)
- .build();
- firebaseApp = FirebaseApp.initializeApp(options, UUID.randomUUID().toString());
- }
- }
-
- public String getDatabaseUrl() {
- return databaseUrl;
- }
-
- public String getRootReference() {
- return rootReference;
- }
-
- public String getServiceAccountFile() {
- return serviceAccountFile;
- }
-
- public String getKeyName() {
- return keyName;
- }
-
- public FirebaseApp getFirebaseApp() {
- return firebaseApp;
- }
-
- public boolean isAsync() {
- return async;
- }
-
- public static class Builder {
-
- private final String databaseUrl;
-
- private final String rootReference;
-
- private final String serviceAccountFile;
-
- private String keyName;
-
- private boolean async;
-
- public Builder(String databaseUrl, String rootReference, String serviceAccountFile) {
- this.databaseUrl = databaseUrl;
- this.rootReference = rootReference;
- this.serviceAccountFile = serviceAccountFile;
- }
-
- public Builder setKeyName(String keyName) {
- this.keyName = keyName;
- return this;
- }
-
- public Builder setAsync(boolean async) {
- this.async = async;
- return this;
- }
-
- public FirebaseConfig build() {
- return new FirebaseConfig(this);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
deleted file mode 100644
index 1dee1a4..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
+++ /dev/null
@@ -1,82 +0,0 @@
-package org.apache.camel.component.firebase;
-
-import com.google.firebase.database.ChildEventListener;
-import com.google.firebase.database.DataSnapshot;
-import com.google.firebase.database.DatabaseError;
-import com.google.firebase.database.FirebaseDatabase;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.component.firebase.data.FirebaseMessage;
-import org.apache.camel.component.firebase.data.Operation;
-import org.apache.camel.component.firebase.exception.FirebaseException;
-import org.apache.camel.impl.DefaultConsumer;
-
-/**
- * Listens to child events of the root reference and forwards the incoming message on the route.
- */
-public class FirebaseConsumer extends DefaultConsumer {
-
- private final FirebaseConfig firebaseConfig;
-
- private final FirebaseEndpoint endpoint;
-
- public FirebaseConsumer(FirebaseEndpoint endpoint, Processor processor) {
- super(endpoint, processor);
- this.endpoint = endpoint;
- firebaseConfig = endpoint.getFirebaseConfig();
- }
-
- @Override
- protected void doStart() throws Exception {
- FirebaseDatabase
- .getInstance(endpoint.getFirebaseApp())
- .getReference(firebaseConfig.getRootReference())
- .addChildEventListener(new ChildEventListener() {
- @Override
- public void onChildAdded(DataSnapshot dataSnapshot, String s) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_ADD, dataSnapshot)
- .setPreviousChildName(s).build());
- }
-
- @Override
- public void onChildChanged(DataSnapshot dataSnapshot, String s) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_CHANGED, dataSnapshot)
- .setPreviousChildName(s).build());
- }
-
- @Override
- public void onChildRemoved(DataSnapshot dataSnapshot) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_REMOVED, dataSnapshot).build());
- }
-
- @Override
- public void onChildMoved(DataSnapshot dataSnapshot, String s) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_MOVED, dataSnapshot)
- .setPreviousChildName(s).build());
- }
-
- @Override
- public void onCancelled(DatabaseError databaseError) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CANCELLED).setDatabaseError(databaseError)
- .build());
- }
- });
- }
-
- private void forwardMessage(FirebaseMessage o) {
- Exchange exchange = endpoint.createExchange();
- exchange.getIn().setBody(o);
-
- try {
- // send message to next processor in the route
- getProcessor().process(exchange);
- } catch (Exception e) {
- throw new FirebaseException("Message forwarding failed", e);
- } finally {
- // log exception if an exception occurred and was not handled
- if (exchange.getException() != null) {
- getExceptionHandler().handleException("Error processing exchange", exchange, exchange.getException());
- }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
deleted file mode 100644
index 0be796a..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
+++ /dev/null
@@ -1,97 +0,0 @@
-package org.apache.camel.component.firebase;
-
-import com.google.firebase.FirebaseApp;
-import org.apache.camel.Consumer;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.impl.DefaultEndpoint;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
-
-/**
- * Represents a Firebase endpoint.
- */
-@UriEndpoint(scheme = "firebase", title = "Firebase", syntax="firebase:name", consumerClass = FirebaseConsumer.class, label = "Firebase")
-public class FirebaseEndpoint extends DefaultEndpoint {
-
- private final FirebaseConfig firebaseConfig;
-
- @UriParam
- @Metadata(required = "true")
- private String rootReference;
-
- @UriParam
- @Metadata(required = "true")
- private String serviceAccountFile;
-
- @UriParam(defaultValue = "firebaseKey") @Metadata(required = "false")
- private String keyName = "firebaseKey";
-
- @UriParam(defaultValue = "async") @Metadata(required = "false")
- private boolean async;
-
- public FirebaseEndpoint(String uri, FirebaseComponent firebaseComponent, FirebaseConfig firebaseConfig) {
- super(uri, firebaseComponent);
- this.firebaseConfig = firebaseConfig;
- this.setRootReference(firebaseConfig.getRootReference());
- this.setServiceAccountFile(firebaseConfig.getServiceAccountFile());
- final String keyName = firebaseConfig.getKeyName();
- this.setAsync(firebaseConfig.isAsync());
- if(keyName != null) {
- this.setKeyName(keyName);
- }
- }
-
- public Producer createProducer() throws Exception {
- return new FirebaseProducer(this);
- }
-
- public Consumer createConsumer(Processor processor) throws Exception {
- return new FirebaseConsumer(this, processor);
- }
-
- public boolean isSingleton() {
- return true;
- }
-
- public String getRootReference() {
- return rootReference;
- }
-
- public void setRootReference(String rootReference) {
- this.rootReference = rootReference;
- }
-
- public String getServiceAccountFile() {
- return serviceAccountFile;
- }
-
- public void setServiceAccountFile(String serviceAccountFile) {
- this.serviceAccountFile = serviceAccountFile;
- }
-
- public FirebaseConfig getFirebaseConfig() {
- return firebaseConfig;
- }
-
- public String getKeyName() {
- return keyName;
- }
-
- public void setKeyName(String keyName) {
- this.keyName = keyName;
- }
-
- public boolean isAsync() {
- return async;
- }
-
- public void setAsync(boolean async) {
- this.async = async;
- }
-
- public FirebaseApp getFirebaseApp() {
- return firebaseConfig.getFirebaseApp();
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
deleted file mode 100644
index bc09550..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
+++ /dev/null
@@ -1,61 +0,0 @@
-package org.apache.camel.component.firebase;
-
-import com.google.firebase.database.DatabaseError;
-import com.google.firebase.database.DatabaseReference;
-import com.google.firebase.database.FirebaseDatabase;
-import org.apache.camel.AsyncCallback;
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.component.firebase.exception.DatabaseErrorException;
-import org.apache.camel.impl.DefaultAsyncProducer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * The producer, which can be used to set a value for a specific key in Firebase.
- */
-public class FirebaseProducer extends DefaultAsyncProducer {
-
- private static final Logger LOG = LoggerFactory.getLogger(FirebaseProducer.class);
- private final String rootReference;
- private final FirebaseEndpoint endpoint;
-
- public FirebaseProducer(FirebaseEndpoint endpoint) {
- super(endpoint);
- this.endpoint = endpoint;
- rootReference = endpoint.getRootReference();
- }
-
- /**
- * Processes the message exchange.
- * Similar to {@link Processor#process}, but the caller supports having the exchange asynchronously processed.
- * <p/>
- * If there was a failure processing then the caused {@link Exception} would be set on the {@link Exchange}.
- *
- * @param exchange the message exchange
- * @param callback the {@link AsyncCallback} will be invoked when the processing of the exchange is completed.
- * If the exchange is completed synchronously, then the callback is also invoked synchronously.
- * The callback should therefore be careful of starting recursive loop.
- * @return (doneSync) <tt>true</tt> to continue execute synchronously, <tt>false</tt> to continue being executed asynchronously
- */
- @Override
- public boolean process(Exchange exchange, AsyncCallback callback) {
- final Message in = exchange.getIn();
- String firebaseKey = (String) in.getHeader(endpoint.getKeyName());
- Object value = in.getBody();
- DatabaseReference ref = FirebaseDatabase
- .getInstance(endpoint.getFirebaseApp())
- .getReference(rootReference).child(firebaseKey);
- ref.setValue(value, (DatabaseError databaseError, DatabaseReference databaseReference) -> {
- if (databaseError != null) {
- exchange.setException(new DatabaseErrorException(databaseError));
- exchange.getOut().setFault(true);
- } else {
- exchange.getOut().setBody(databaseReference);
- }
- callback.done(endpoint.isAsync());
- });
- return endpoint.isAsync();
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
deleted file mode 100644
index afd02ae..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
+++ /dev/null
@@ -1,88 +0,0 @@
-package org.apache.camel.component.firebase.data;
-
-import com.google.firebase.database.DataSnapshot;
-import com.google.firebase.database.DatabaseError;
-
-/**
- * Contains a message sent by Firebase.
- */
-public class FirebaseMessage {
-
- private final Operation operation;
-
- private final DataSnapshot dataSnapshot;
-
- private final String previousChildName;
-
- private final DatabaseError databaseError;
-
- private FirebaseMessage(Builder builder) {
- this.operation = builder.operation;
- this.dataSnapshot = builder.dataSnapshot;
- this.previousChildName = builder.previousChildName;
- this.databaseError = builder.databaseError;
- }
-
- public Operation getOperation() {
- return operation;
- }
-
- public DataSnapshot getDataSnapshot() {
- return dataSnapshot;
- }
-
- public String getPreviousChildName() {
- return previousChildName;
- }
-
- public DatabaseError getDatabaseError() {
- return databaseError;
- }
-
- @Override
- public String toString() {
- return "FirebaseMessage{" + "operation=" + operation +
- ", dataSnapshot=" + dataSnapshot +
- ", previousChildName='" + previousChildName + '\'' +
- ", databaseError=" + databaseError +
- '}';
- }
-
- public static class Builder {
- private final Operation operation;
-
- private DataSnapshot dataSnapshot;
-
- private String previousChildName;
-
- private DatabaseError databaseError;
-
- public Builder(Operation operation) {
- this.operation = operation;
- }
-
- public Builder(Operation operation, DataSnapshot dataSnapshot) {
- this.operation = operation;
- this.dataSnapshot = dataSnapshot;
- }
-
- public Builder setPreviousChildName(String previousChildName) {
- this.previousChildName = previousChildName;
- return this;
- }
-
- public Builder setDataSnapshot(DataSnapshot dataSnapshot) {
- this.dataSnapshot = dataSnapshot;
- return this;
- }
-
- public Builder setDatabaseError(DatabaseError databaseError) {
- this.databaseError = databaseError;
- return this;
- }
-
- public FirebaseMessage build() {
- return new FirebaseMessage(this);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java
deleted file mode 100644
index 5410c61..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package org.apache.camel.component.firebase.data;
-
-/**
- * Operations associated with the messages.
- */
-public enum Operation {
-
- CHILD_ADD,
- CHILD_CHANGED,
- CHILD_REMOVED,
- CHILD_MOVED,
- CANCELLED
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java
deleted file mode 100644
index 4c2d23e..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package org.apache.camel.component.firebase.exception;
-
-import com.google.firebase.database.DatabaseError;
-
-/**
- * In case Firebase throws a database error, this object wraps a Throwable around the original object.
- */
-public class DatabaseErrorException extends RuntimeException {
-
- private final DatabaseError databaseError;
-
- public DatabaseErrorException(DatabaseError databaseError) {
- super();
- this.databaseError = databaseError;
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
deleted file mode 100644
index 190f386..0000000
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
+++ /dev/null
@@ -1,57 +0,0 @@
-package org.apache.camel.component.firebase.exception;
-
-import com.google.firebase.database.DatabaseError;
-
-/**
- * Used to mark an exception occurred in the Firebase Camel processor.
- */
-public class FirebaseException extends RuntimeException {
-
- private DatabaseError databaseError;
-
- /**
- * Constructs a new runtime exception with {@code null} as its
- * detail message. The cause is not initialized, and may subsequently be
- * initialized by a call to {@link #initCause}.
- */
- public FirebaseException() {
- }
-
- /**
- * Constructs a new runtime exception with the specified detail message.
- * The cause is not initialized, and may subsequently be initialized by a
- * call to {@link #initCause}.
- *
- * @param message the detail message. The detail message is saved for
- * later retrieval by the {@link #getMessage()} method.
- */
- public FirebaseException(String message) {
- super(message);
- }
-
- /**
- * Constructs a new runtime exception with the specified detail message and
- * cause. <p>Note that the detail message associated with
- * {@code cause} is <i>not</i> automatically incorporated in
- * this runtime exception's detail message.
- *
- * @param message the detail message (which is saved for later retrieval
- * by the {@link #getMessage()} method).
- * @param cause the cause (which is saved for later retrieval by the
- * {@link #getCause()} method). (A <tt>null</tt> value is
- * permitted, and indicates that the cause is nonexistent or
- * unknown.)
- * @since 1.4
- */
- public FirebaseException(String message, Throwable cause) {
- super(message, cause);
- }
-
- public void setDatabaseError(DatabaseError databaseError) {
- this.databaseError = databaseError;
- }
-
- public DatabaseError getDatabaseError() {
- return databaseError;
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt b/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt
deleted file mode 100644
index 5861116..0000000
--- a/components/camel-firebase/src/main/resources/META-INF/LICENSE.txt
+++ /dev/null
@@ -1,203 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
- http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that is based on (or derived from) the Work and for which the
- editorial revisions, annotations, elaborations, or other modifications
- represent, as a whole, an original work of authorship. For the purposes
- of this License, Derivative Works shall not include works that remain
- separable from, or merely link (or bind by name) to the interfaces of,
- the Work and Derivative Works thereof.
-
- "Contribution" shall mean any work of authorship, including
- the original version of the Work and any modifications or additions
- to that Work or Derivative Works thereof, that is intentionally
- submitted to Licensor for inclusion in the Work by the copyright owner
- or by an individual or Legal Entity authorized to submit on behalf of
- the copyright owner. For the purposes of this definition, "submitted"
- means any form of electronic, verbal, or written communication sent
- to the Licensor or its representatives, including but not limited to
- communication on electronic mailing lists, source code control systems,
- and issue tracking systems that are managed by, or on behalf of, the
- Licensor for the purpose of discussing and improving the Work, but
- excluding communication that is conspicuously marked or otherwise
- designated in writing by the copyright owner as "Not a Contribution."
-
- "Contributor" shall mean Licensor and any individual or Legal Entity
- on behalf of whom a Contribution has been received by Licensor and
- subsequently incorporated within the Work.
-
- 2. Grant of Copyright License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- copyright license to reproduce, prepare Derivative Works of,
- publicly display, publicly perform, sublicense, and distribute the
- Work and such Derivative Works in Source or Object form.
-
- 3. Grant of Patent License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- (except as stated in this section) patent license to make, have made,
- use, offer to sell, sell, import, and otherwise transfer the Work,
- where such license applies only to those patent claims licensable
- by such Contributor that are necessarily infringed by their
- Contribution(s) alone or by combination of their Contribution(s)
- with the Work to which such Contribution(s) was submitted. If You
- institute patent litigation against any entity (including a
- cross-claim or counterclaim in a lawsuit) alleging that the Work
- or a Contribution incorporated within the Work constitutes direct
- or contributory patent infringement, then any patent licenses
- granted to You under this License for that Work shall terminate
- as of the date such litigation is filed.
-
- 4. Redistribution. You may reproduce and distribute copies of the
- Work or Derivative Works thereof in any medium, with or without
- modifications, and in Source or Object form, provided that You
- meet the following conditions:
-
- (a) You must give any other recipients of the Work or
- Derivative Works a copy of this License; and
-
- (b) You must cause any modified files to carry prominent notices
- stating that You changed the files; and
-
- (c) You must retain, in the Source form of any Derivative Works
- that You distribute, all copyright, patent, trademark, and
- attribution notices from the Source form of the Work,
- excluding those notices that do not pertain to any part of
- the Derivative Works; and
-
- (d) If the Work includes a "NOTICE" text file as part of its
- distribution, then any Derivative Works that You distribute must
- include a readable copy of the attribution notices contained
- within such NOTICE file, excluding those notices that do not
- pertain to any part of the Derivative Works, in at least one
- of the following places: within a NOTICE text file distributed
- as part of the Derivative Works; within the Source form or
- documentation, if provided along with the Derivative Works; or,
- within a display generated by the Derivative Works, if and
- wherever such third-party notices normally appear. The contents
- of the NOTICE file are for informational purposes only and
- do not modify the License. You may add Your own attribution
- notices within Derivative Works that You distribute, alongside
- or as an addendum to the NOTICE text from the Work, provided
- that such additional attribution notices cannot be construed
- as modifying the License.
-
- You may add Your own copyright statement to Your modifications and
- may provide additional or different license terms and conditions
- for use, reproduction, or distribution of Your modifications, or
- for any such Derivative Works as a whole, provided Your use,
- reproduction, and distribution of the Work otherwise complies with
- the conditions stated in this License.
-
- 5. Submission of Contributions. Unless You explicitly state otherwise,
- any Contribution intentionally submitted for inclusion in the Work
- by You to the Licensor shall be under the terms and conditions of
- this License, without any additional terms or conditions.
- Notwithstanding the above, nothing herein shall supersede or modify
- the terms of any separate license agreement you may have executed
- with Licensor regarding such Contributions.
-
- 6. Trademarks. This License does not grant permission to use the trade
- names, trademarks, service marks, or product names of the Licensor,
- except as required for reasonable and customary use in describing the
- origin of the Work and reproducing the content of the NOTICE file.
-
- 7. Disclaimer of Warranty. Unless required by applicable law or
- agreed to in writing, Licensor provides the Work (and each
- Contributor provides its Contributions) on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- implied, including, without limitation, any warranties or conditions
- of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
- PARTICULAR PURPOSE. You are solely responsible for determining the
- appropriateness of using or redistributing the Work and assume any
- risks associated with Your exercise of permissions under this License.
-
- 8. Limitation of Liability. In no event and under no legal theory,
- whether in tort (including negligence), contract, or otherwise,
- unless required by applicable law (such as deliberate and grossly
- negligent acts) or agreed to in writing, shall any Contributor be
- liable to You for damages, including any direct, indirect, special,
- incidental, or consequential damages of any character arising as a
- result of this License or out of the use or inability to use the
- Work (including but not limited to damages for loss of goodwill,
- work stoppage, computer failure or malfunction, or any and all
- other commercial damages or losses), even if such Contributor
- has been advised of the possibility of such damages.
-
- 9. Accepting Warranty or Additional Liability. While redistributing
- the Work or Derivative Works thereof, You may choose to offer,
- and charge a fee for, acceptance of support, warranty, indemnity,
- or other liability obligations and/or rights consistent with this
- License. However, in accepting such obligations, You may act only
- on Your own behalf and on Your sole responsibility, not on behalf
- of any other Contributor, and only if You agree to indemnify,
- defend, and hold each Contributor harmless for any liability
- incurred by, or claims asserted against, such Contributor by reason
- of your accepting any such warranty or additional liability.
-
- END OF TERMS AND CONDITIONS
-
- APPENDIX: How to apply the Apache License to your work.
-
- To apply the Apache License to your work, attach the following
- boilerplate notice, with the fields enclosed by brackets "[]"
- replaced with your own identifying information. (Don't include
- the brackets!) The text should be enclosed in the appropriate
- comment syntax for the file format. We also recommend that a
- file or class name and description of purpose be included on the
- same "printed page" as the copyright notice for easier
- identification within third-party archives.
-
- Copyright 2016 Onepoint Ltd
-
- Licensed 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.
-
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase b/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase
deleted file mode 100644
index 24a2a7b7..0000000
--- a/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase
+++ /dev/null
@@ -1 +0,0 @@
-class=org.apache.camel.component.firebase.FirebaseComponent
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java
deleted file mode 100644
index 460a7e7..0000000
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java
+++ /dev/null
@@ -1,87 +0,0 @@
-package org.apache.camel.component.firebase;
-
-import com.google.firebase.database.DatabaseReference;
-import com.google.firebase.database.FirebaseDatabase;
-import org.apache.camel.CamelContext;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.firebase.data.FirebaseMessage;
-import org.apache.camel.component.firebase.data.Operation;
-import org.apache.camel.component.firebase.provider.ConfigurationProvider;
-import org.apache.camel.component.firebase.provider.SampleInputProvider;
-import org.apache.camel.impl.DefaultCamelContext;
-import org.junit.Test;
-
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.locks.Condition;
-import java.util.concurrent.locks.ReentrantLock;
-
-import static junit.framework.TestCase.fail;
-import static org.assertj.core.api.Assertions.assertThat;
-
-/**
- * Starts a route which listens to the remove event in Firebase. It then writes and deletes an entry in Firebase and
- * asserts, if the entry was deleted or not.
- */
-public class FirebaseConsumerDeleteTest {
-
- private final ReentrantLock reentrantLock = new ReentrantLock();
-
- private final Condition wake = reentrantLock.newCondition();
-
- @Test
- public void whenDelete_DeleteMessageShouldBeIntercepted() throws Exception {
- CamelContext context = new DefaultCamelContext();
- boolean[] deleteMessageReceived = { false };
- FirebaseConfig firebaseConfig = ConfigurationProvider.createDemoConfig();
- setupRoute(context, deleteMessageReceived);
- context.addStartupListener((context1, alreadyStarted) -> {
- TimeUnit.SECONDS.sleep(5);
- createAndDeleteContent(firebaseConfig);
- });
- context.start();
- try {
- reentrantLock.lock();
- wake.await(30, TimeUnit.SECONDS);
- } finally {
- reentrantLock.unlock();
- }
- assertThat(deleteMessageReceived[0]).isTrue();
- context.stop();
- }
-
- private void createAndDeleteContent(FirebaseConfig firebaseConfig) {
- final DatabaseReference rootReference = FirebaseDatabase.getInstance(firebaseConfig.getFirebaseApp())
- .getReference(ConfigurationProvider.createRootReference()).child(SampleInputProvider.createDeleteKey());
- rootReference
- .setValue("AETHELWULF 839-856", (databaseError, databaseReference) -> {
- databaseReference.removeValue();
- });
- }
-
- private void setupRoute(CamelContext context, final boolean[] deleteMessageReceived) throws Exception {
- context.addRoutes(new RouteBuilder() {
- public void configure() {
- try {
- from(String.format("firebase://%s?rootReference=%s&serviceAccountFile=%s",
- ConfigurationProvider.createDatabaseUrl(), ConfigurationProvider.createRootReference(), ConfigurationProvider.createFirebaseConfigLink()))
- .to("log:firebasetest?level=WARN")
- .process(exchange -> {
- FirebaseMessage firebaseMessage = (FirebaseMessage) exchange.getIn().getBody();
- if (firebaseMessage.getOperation() == Operation.CHILD_REMOVED) {
- deleteMessageReceived[0] = true;
- try {
- reentrantLock.lock();
- wake.signal();
- } finally {
- reentrantLock.unlock();
- }
- }
- });
-
- } catch (Exception e) {
- fail(e.toString());
- }
- }
- });
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java
deleted file mode 100644
index 2c6cbc4..0000000
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java
+++ /dev/null
@@ -1,77 +0,0 @@
-package org.apache.camel.component.firebase;
-
-import com.google.firebase.database.FirebaseDatabase;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.firebase.provider.ConfigurationProvider;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit4.CamelTestSupport;
-import org.junit.Test;
-
-import java.io.IOException;
-import java.net.URLDecoder;
-import java.net.URLEncoder;
-import java.util.concurrent.locks.Condition;
-import java.util.concurrent.locks.ReentrantLock;
-
-/**
- * Writes a dummy message and then checks, if the consumer receives at least one message.
- */
-public class FirebaseConsumerTest extends CamelTestSupport {
-
- @Test
- public void whenFirebaseListener_ShouldReceiveMessages() throws Exception {
- MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMinimumMessageCount(1);
- assertMockEndpointsSatisfied();
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- final String databaseUrl = "gil-sample-app.firebaseio.com";
- final String originalRootReference = "server/saving-data";
- String serviceAccountFile = ConfigurationProvider.createFirebaseConfigLink();
- String rootReference = URLEncoder.encode(originalRootReference, "UTF-8");
- insertDummyData(String.format("https://%s", databaseUrl), originalRootReference, serviceAccountFile);
-
- return new RouteBuilder() {
- public void configure() {
- try {
- from(String.format("firebase://" + databaseUrl + "?rootReference=%s&serviceAccountFile=%s",
- rootReference, serviceAccountFile))
- .to("log:firebasetest?level=WARN")
- .to("mock:result");
- } catch (Exception e) {
- fail(e.toString());
- }
- }
- };
- }
-
- private final ReentrantLock lock = new ReentrantLock();
-
- private final Condition wake = lock.newCondition();
-
- private void insertDummyData(String databaseUrl, String originalRootReference, String serviceAccountFile) throws IOException, InterruptedException {
- FirebaseConfig config = new FirebaseConfig.Builder(databaseUrl, originalRootReference, URLDecoder.decode(serviceAccountFile, "UTF-8"))
- .build();
- config.init();
- FirebaseDatabase
- .getInstance(config.getFirebaseApp())
- .getReference(config.getRootReference()).child("dummy").setValue("test", (databaseError, databaseReference) -> {
- try {
- lock.lock();
- wake.signal();
- }
- finally {
- lock.unlock();
- }
- });
- try {
- lock.lock();
- wake.await();
- }
- finally {
- lock.unlock();
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
deleted file mode 100644
index 75dd869..0000000
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
+++ /dev/null
@@ -1,91 +0,0 @@
-package org.apache.camel.component.firebase;
-
-import com.google.firebase.database.DatabaseReference;
-import org.apache.camel.CamelContext;
-import org.apache.camel.Message;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.file.GenericFile;
-import org.apache.camel.component.firebase.provider.ConfigurationProvider;
-import org.apache.camel.component.firebase.provider.SampleInputProvider;
-import org.apache.camel.impl.DefaultCamelContext;
-import org.junit.Before;
-import org.junit.Test;
-
-import java.net.URLEncoder;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.util.concurrent.locks.Condition;
-import java.util.concurrent.locks.ReentrantLock;
-
-import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
-
-/**
- * Tests two scenarios: a synchronous and one asynchronous request.
- */
-public class FirebaseProducerTest {
-
- private final ReentrantLock reentrantLock = new ReentrantLock();
-
- private final Condition wake = reentrantLock.newCondition();
-
- private SampleInputProvider sampleInputProvider;
-
- @Before
- public void setUp() throws Exception {
- sampleInputProvider = new SampleInputProvider();
- }
-
- @Test
- public void whenFirebaseSet_ShouldReceiveMessagesSync() throws Exception {
- startRoute(false, DatabaseReference.class);
- }
-
- @Test
- public void whenFirebaseSet_ShouldReceiveMessagesAsync() throws Exception {
- startRoute(true, String.class);
- }
-
-
- private void startRoute(final boolean async, final Class<?> expectedBodyClass) throws Exception {
- sampleInputProvider.copySampleFile();
- CamelContext context = new DefaultCamelContext();
- context.addRoutes(new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- String rootReference = URLEncoder.encode(ConfigurationProvider.createRootReference(), "UTF-8");
- String serviceAccountFile = ConfigurationProvider.createFirebaseConfigLink();
- from(sampleInputProvider.getTargetFolder().toUri().toString())
- .process(exchange -> {
- GenericFile file = (GenericFile) exchange.getIn().getBody();
- String content = new String(Files.readAllBytes(Paths.get(file.getAbsoluteFilePath())), "UTF-8");
- String[] keyValue = content.split("=");
- final Message out = exchange.getOut();
- out.setHeader("firebaseKey", keyValue[0]);
- out.setBody(keyValue[1].trim());
- })
- .to(String.format("firebase://%s?rootReference=%s&serviceAccountFile=%s&async=%b",
- ConfigurationProvider.createDatabaseUrl(), rootReference, serviceAccountFile, async))
- .to("log:whenFirebaseSet?level=WARN")
- .process(exchange1 -> {
- assertThat(exchange1.getIn().getBody().getClass()).isEqualTo(expectedBodyClass);
- try{
- reentrantLock.lock();
- wake.signal();
- }
- finally {
- reentrantLock.unlock();
- }
- });
- }
- });
- context.start();
- try{
- reentrantLock.lock();
- wake.await();
- }
- finally {
- reentrantLock.unlock();
- }
- context.stop();
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
deleted file mode 100644
index 666abf7..0000000
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
+++ /dev/null
@@ -1,41 +0,0 @@
-package org.apache.camel.component.firebase.provider;
-
-import org.apache.camel.component.firebase.FirebaseConfig;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.UnsupportedEncodingException;
-import java.net.URISyntaxException;
-import java.net.URL;
-import java.net.URLDecoder;
-import java.net.URLEncoder;
-
-import static org.junit.Assert.assertNotNull;
-
-/**
- * Provides the path of the configuration used to access Firebase.
- */
-public class ConfigurationProvider {
-
- public static String createFirebaseConfigLink() throws URISyntaxException, UnsupportedEncodingException {
- URL url = Thread.currentThread().getContextClassLoader().getResource("gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json");
- assertNotNull(url);
- File f = new File(url.toURI());
- return URLEncoder.encode(f.getAbsolutePath(), "UTF-8");
- }
-
- public static FirebaseConfig createDemoConfig() throws IOException, URISyntaxException {
- FirebaseConfig firebaseConfig = new FirebaseConfig.Builder(String.format("https://%s", createDatabaseUrl()), createRootReference(),
- URLDecoder.decode(createFirebaseConfigLink(), "UTF-8")).build();
- firebaseConfig.init();
- return firebaseConfig;
- }
-
- public static String createRootReference() {
- return "server/saving-data";
- }
-
- public static String createDatabaseUrl() {
- return "gil-sample-app.firebaseio.com";
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java
deleted file mode 100644
index 4b0d4f7..0000000
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java
+++ /dev/null
@@ -1,44 +0,0 @@
-package org.apache.camel.component.firebase.provider;
-
-import java.io.IOException;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.net.URL;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.nio.file.StandardCopyOption;
-
-import static org.assertj.core.api.Assertions.assertThat;
-
-/**
- * Copies a test file to a folder to test routes.
- */
-public class SampleInputProvider {
-
- private final Path targetFolder;
-
- public SampleInputProvider() throws IOException {
- targetFolder = Paths.get("src/data");
- if(!Files.exists(targetFolder)) {
- Files.createDirectories(targetFolder);
- }
- }
-
- public void copySampleFile() throws URISyntaxException, IOException {
- final String name = "sample_message.txt";
- URL url = Thread.currentThread().getContextClassLoader().getResource(name);
- assertThat(url).isNotNull();
- final URI uri = url.toURI();
- Path sourceFile = Paths.get(uri);
- Files.copy(sourceFile, targetFolder.resolve(name), StandardCopyOption.REPLACE_EXISTING);
- }
-
- public Path getTargetFolder() {
- return targetFolder;
- }
-
- public static String createDeleteKey() {
- return "second king of Saxony";
- }
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json b/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
deleted file mode 100644
index 7a9f352..0000000
--- a/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
+++ /dev/null
@@ -1,12 +0,0 @@
-{
- "type": "service_account",
- "project_id": "gil-sample-app",
- "private_key_id": "fea519a672d21f7667afb1badbeb858342ae32ac",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDX88p2HcAn2z0t\n7uAk0jB0RUyi4f+SWd3ofM6Ju59XLyttnbXKEYNBnjIE3YOJ49Xd92vFXGsYU+DU\nb7vFf/rXtfiZglE6zHF8p+53Jy/AJKWHLWKa+nZa4vUQASmBGJy5SF37YJhaE/Mu\nUqNESdZowdjro4bE3D/VYZsK/9UmHEO8PmlKL9Igl4WVq5I1toJk1eae/2nBmE3+\n3/uGrTf6ydJ8xx/tPMwWGLRNYxb4PQliTTCaLc5dR/p9B8YMwMtuxWU9IereIKp8\n51ZgYW6e/6IHbfb22cp2NwKHxwvnZu5HZ1+IIZ+3n9S2OJYZGPBIB7xJzSd6xXAf\nXAQqYzMDAgMBAAECggEAYfbEJ6UDYJFCRa4RnGKFfJlbVKC1MYz279p+T1j/xasu\nRkG/D/W113SOOErMuybSBCmTiCqOorCaU4SEZ+nQvz5bkjfd5ZCNAwGjWgY60S1O\nse3Sx39LZZuDlEkSrO+fWSYNDFYbhvF55c+zJO1iCI+3ed3q6y8G/iOTFABOj0R5\nZ7pPJqzXIg3sKRaMOJ+l2F8/nIZ8AUyesByJgP4UuyYTb9LaqRqIz/URYh2xVohW\n3MkXmCDkY5tyzJ7rwJloHoOo4Hsvefzgv3dDJYu4FJ7BUHFyNa6yZDGdte49WQsS\nDNEwEDvBPsE00olbsjAkSpdC0u57836Vn81Xz84y4QKBgQD63EWzFrVx0w+8PSy8\nPqZgQWEwHb09r2c9TjaxqohtapqFZZ5szEiOOad8r369RQ6bVIMzYzYRBUGDkZj7\nmDBB1lglgYC+NEHZAaObXPzVngAN3fRW7a+IRQLOlYqd8Er0v0jw37R6PjAXFz/5\nFtnX0eMnA0MfNqN9mhKyvgX7mQ
KBgQDcYG4sUOSIO3BG7z9ufL0aiyfERFg6gTJ1\n05xXVNHJBRh+nu6bXPp+a76myiR0QPhXhKuok7PC4opcmreeN4401MGSStgp4Xng\nM/vpMd3knw0zn9DY5FrFdxtIs8YFBcu2XkJzz+rM1IAw563wLRQAuUbb+AOtspZ1\noDZ2ssQk+wKBgE+Oa8xP91sRxHu+KuHIPJtqIJhR1iIp7mPS2iWeH4YTuM11XLjE\nUH5KaoNwZJFBxVAdjT5OyGa9c/l1wz6HFUbL40iBuYKYsAlSK8CpzMUyRnIfYc3v\nsytUN3+sjTlpa1wTDd7WEzZxYm7wQKmORafcOF22+yJ7AX5jzmpBOUSBAoGBAIkY\nLDHBeQoPAAAA4hMX4oRawThl1AVBTmTiacYibAeD9gL/WCyqoOJ4oLgd1KPFrziy\nvh83E4NPbwfA8C2rHfpbyLf7e5JCRJFnhXVCommRUKMm7sOe+6EQQZbuz2dcfahL\n50cot0cJg13pItnhESqKGDzLg25RRSyTqI4bE851AoGAHAixBamIjbFDuSxx9wQ6\n8qy1eB0h66BvZ+YWrXaI6v9zBBSRrdnda35oFVAOFV4LZ6NNsg88ODX/kt9vU5CB\nEmQYAwLLh6vrmw59JifoNIv47GnxGbpCkp9SFhmkiJbyAJiEjAjAtz8HulY1Biqs\nGHkPENC3ZATt4yXI76C5ktU=\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-rcwg7@gil-sample-app.iam.gserviceaccount.com",
- "client_id": "107121076566697579073",
- "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
- "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-rcwg7%40gil-sample-app.iam.gserviceaccount.com"
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/test/resources/log4j2.properties
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/log4j2.properties b/components/camel-firebase/src/test/resources/log4j2.properties
deleted file mode 100644
index 328db35..0000000
--- a/components/camel-firebase/src/test/resources/log4j2.properties
+++ /dev/null
@@ -1,7 +0,0 @@
-
-appender.out.type = Console
-appender.out.name = out
-appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = [%30.30t] %-30.30c{1} %-5p %m%n
-rootLogger.level = INFO
-rootLogger.appenderRef.out.ref = out
http://git-wip-us.apache.org/repos/asf/camel/blob/e234e4fd/components/camel-firebase/src/test/resources/sample_message.txt
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/sample_message.txt b/components/camel-firebase/src/test/resources/sample_message.txt
deleted file mode 100644
index 852f717..0000000
--- a/components/camel-firebase/src/test/resources/sample_message.txt
+++ /dev/null
@@ -1 +0,0 @@
-FIRST KIND OF ENGLAND=Egbert
\ No newline at end of file
[22/28] camel git commit: Revert "Added profile which executed all
integration tests."
Posted by ac...@apache.org.
Revert "Added profile which executed all integration tests."
This reverts commit a82142cdc56ce2cf1bd9884f3f27540d004c3b5c.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e898247b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e898247b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e898247b
Branch: refs/heads/master
Commit: e898247b51498467425b41602a0f76afb00f218c
Parents: cd88ad1
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:19 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:19 2016 +0100
----------------------------------------------------------------------
components/camel-firebase/pom.xml | 15 ---------------
1 file changed, 15 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/e898247b/components/camel-firebase/pom.xml
----------------------------------------------------------------------
diff --git a/components/camel-firebase/pom.xml b/components/camel-firebase/pom.xml
index e444bed..ad76990 100644
--- a/components/camel-firebase/pom.xml
+++ b/components/camel-firebase/pom.xml
@@ -17,7 +17,6 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<firebase.version>4.0.1</firebase.version>
- <maven.test.skip>true</maven.test.skip>
</properties>
<dependencies>
@@ -63,18 +62,4 @@
</dependency>
</dependencies>
- <profiles>
- <!-- Use this profile in case you want to run the tests -->
- <!-- Make sure that the file firebase-admin-connection.json contains the right parameters -->
- <profile>
- <id>firebase-integration-test</id>
- <properties>
- <maven.test.skip>false</maven.test.skip>
- </properties>
- <activation>
- <activeByDefault>false</activeByDefault>
- </activation>
- </profile>
- </profiles>
-
</project>
\ No newline at end of file
[26/28] camel git commit: Revert "Committed renamed firebase
connection file."
Posted by ac...@apache.org.
Revert "Committed renamed firebase connection file."
This reverts commit e7fa94dd7c287e44d66c390a9d6888a1a7cc8060.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e8539312
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e8539312
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e8539312
Branch: refs/heads/master
Commit: e853931296dd23d1b747f01e533c4bb3ebf3692e
Parents: ced32a8
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:35 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:35 2016 +0100
----------------------------------------------------------------------
.../camel/component/firebase/FirebaseProducerTest.java | 1 +
.../firebase/provider/ConfigurationProvider.java | 2 +-
.../src/test/resources/firebase-admin-connection.json | 12 ------------
...l-sample-app-firebase-adminsdk-rcwg7-fea519a672.json | 12 ++++++++++++
4 files changed, 14 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/e8539312/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
index 549bfef..75dd869 100644
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
+++ b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
@@ -45,6 +45,7 @@ public class FirebaseProducerTest {
startRoute(true, String.class);
}
+
private void startRoute(final boolean async, final Class<?> expectedBodyClass) throws Exception {
sampleInputProvider.copySampleFile();
CamelContext context = new DefaultCamelContext();
http://git-wip-us.apache.org/repos/asf/camel/blob/e8539312/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
index d33d881..666abf7 100644
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
+++ b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
@@ -18,7 +18,7 @@ import static org.junit.Assert.assertNotNull;
public class ConfigurationProvider {
public static String createFirebaseConfigLink() throws URISyntaxException, UnsupportedEncodingException {
- URL url = Thread.currentThread().getContextClassLoader().getResource("firebase-admin-connection.json");
+ URL url = Thread.currentThread().getContextClassLoader().getResource("gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json");
assertNotNull(url);
File f = new File(url.toURI());
return URLEncoder.encode(f.getAbsolutePath(), "UTF-8");
http://git-wip-us.apache.org/repos/asf/camel/blob/e8539312/components/camel-firebase/src/test/resources/firebase-admin-connection.json
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/firebase-admin-connection.json b/components/camel-firebase/src/test/resources/firebase-admin-connection.json
deleted file mode 100644
index 69feae7..0000000
--- a/components/camel-firebase/src/test/resources/firebase-admin-connection.json
+++ /dev/null
@@ -1,12 +0,0 @@
-{
- "type": "service_account",
- "project_id": "gil-sample-app",
- "private_key_id": "",
- "private_key": "",
- "client_email": "",
- "client_id": "107121076566697579073",
- "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
- "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-rcwg7%40gil-sample-app.iam.gserviceaccount.com"
-}
http://git-wip-us.apache.org/repos/asf/camel/blob/e8539312/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json b/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
new file mode 100644
index 0000000..69feae7
--- /dev/null
+++ b/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
@@ -0,0 +1,12 @@
+{
+ "type": "service_account",
+ "project_id": "gil-sample-app",
+ "private_key_id": "",
+ "private_key": "",
+ "client_email": "",
+ "client_id": "107121076566697579073",
+ "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+ "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-rcwg7%40gil-sample-app.iam.gserviceaccount.com"
+}
[05/28] camel git commit: Revert "Camel-Firebase: Added to kit"
Posted by ac...@apache.org.
Revert "Camel-Firebase: Added to kit"
This reverts commit b261ee64a692c5209e7f04168476aebca6ec91dd.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1a16facb
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1a16facb
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1a16facb
Branch: refs/heads/master
Commit: 1a16facbdfe764f5ce3e8ed1dfef84fd5a5d88a0
Parents: ae1fdbc
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:38 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:38 2016 +0100
----------------------------------------------------------------------
apache-camel/pom.xml | 4 ----
apache-camel/src/main/descriptors/common-bin.xml | 1 -
2 files changed, 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/1a16facb/apache-camel/pom.xml
----------------------------------------------------------------------
diff --git a/apache-camel/pom.xml b/apache-camel/pom.xml
index 72894cf..f404cab 100644
--- a/apache-camel/pom.xml
+++ b/apache-camel/pom.xml
@@ -271,10 +271,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-firebase</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-flatpack</artifactId>
</dependency>
<dependency>
http://git-wip-us.apache.org/repos/asf/camel/blob/1a16facb/apache-camel/src/main/descriptors/common-bin.xml
----------------------------------------------------------------------
diff --git a/apache-camel/src/main/descriptors/common-bin.xml b/apache-camel/src/main/descriptors/common-bin.xml
index 021c3cb..ece1c26 100644
--- a/apache-camel/src/main/descriptors/common-bin.xml
+++ b/apache-camel/src/main/descriptors/common-bin.xml
@@ -79,7 +79,6 @@
<include>org.apache.camel:camel-eventadmin</include>
<include>org.apache.camel:camel-exec</include>
<include>org.apache.camel:camel-facebook</include>
- <include>org.apache.camel:camel-firebase</include>
<include>org.apache.camel:camel-flatpack</include>
<include>org.apache.camel:camel-flink</include>
<include>org.apache.camel:camel-fop</include>
[09/28] camel git commit: Revert "Added the ASF license header."
Posted by ac...@apache.org.
Revert "Added the ASF license header."
This reverts commit c98918856a8fb67d3ea535c971af4b016b168a6d.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/24fe56b8
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/24fe56b8
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/24fe56b8
Branch: refs/heads/master
Commit: 24fe56b8ac5f148c4b3565327dba670c12445b0e
Parents: 905b87c
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:49 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:49 2016 +0100
----------------------------------------------------------------------
components/camel-firebase/pom.xml | 16 ----------------
1 file changed, 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/24fe56b8/components/camel-firebase/pom.xml
----------------------------------------------------------------------
diff --git a/components/camel-firebase/pom.xml b/components/camel-firebase/pom.xml
index 232ef48..c5944dd 100644
--- a/components/camel-firebase/pom.xml
+++ b/components/camel-firebase/pom.xml
@@ -1,20 +1,4 @@
<?xml version="1.0" encoding="UTF-8"?>
-<!--
- 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.
--->
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
[24/28] camel git commit: Revert "Removed sensitive data."
Posted by ac...@apache.org.
Revert "Removed sensitive data."
This reverts commit 8a4a3cdef37d3fd4d80dc7a6d9523ec03832cea4.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c7112947
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c7112947
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c7112947
Branch: refs/heads/master
Commit: c7112947a80d85c7796af5b74799a70a9ed8d584
Parents: 25dbd0d
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:30 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:30 2016 +0100
----------------------------------------------------------------------
.../src/test/resources/firebase-admin-connection.json | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/c7112947/components/camel-firebase/src/test/resources/firebase-admin-connection.json
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/firebase-admin-connection.json b/components/camel-firebase/src/test/resources/firebase-admin-connection.json
index 62690fa..7a9f352 100644
--- a/components/camel-firebase/src/test/resources/firebase-admin-connection.json
+++ b/components/camel-firebase/src/test/resources/firebase-admin-connection.json
@@ -1,10 +1,10 @@
{
"type": "service_account",
"project_id": "gil-sample-app",
- "private_key_id": "",
- "private_key": "",
- "client_email": "",
- "client_id": "",
+ "private_key_id": "fea519a672d21f7667afb1badbeb858342ae32ac",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDX88p2HcAn2z0t\n7uAk0jB0RUyi4f+SWd3ofM6Ju59XLyttnbXKEYNBnjIE3YOJ49Xd92vFXGsYU+DU\nb7vFf/rXtfiZglE6zHF8p+53Jy/AJKWHLWKa+nZa4vUQASmBGJy5SF37YJhaE/Mu\nUqNESdZowdjro4bE3D/VYZsK/9UmHEO8PmlKL9Igl4WVq5I1toJk1eae/2nBmE3+\n3/uGrTf6ydJ8xx/tPMwWGLRNYxb4PQliTTCaLc5dR/p9B8YMwMtuxWU9IereIKp8\n51ZgYW6e/6IHbfb22cp2NwKHxwvnZu5HZ1+IIZ+3n9S2OJYZGPBIB7xJzSd6xXAf\nXAQqYzMDAgMBAAECggEAYfbEJ6UDYJFCRa4RnGKFfJlbVKC1MYz279p+T1j/xasu\nRkG/D/W113SOOErMuybSBCmTiCqOorCaU4SEZ+nQvz5bkjfd5ZCNAwGjWgY60S1O\nse3Sx39LZZuDlEkSrO+fWSYNDFYbhvF55c+zJO1iCI+3ed3q6y8G/iOTFABOj0R5\nZ7pPJqzXIg3sKRaMOJ+l2F8/nIZ8AUyesByJgP4UuyYTb9LaqRqIz/URYh2xVohW\n3MkXmCDkY5tyzJ7rwJloHoOo4Hsvefzgv3dDJYu4FJ7BUHFyNa6yZDGdte49WQsS\nDNEwEDvBPsE00olbsjAkSpdC0u57836Vn81Xz84y4QKBgQD63EWzFrVx0w+8PSy8\nPqZgQWEwHb09r2c9TjaxqohtapqFZZ5szEiOOad8r369RQ6bVIMzYzYRBUGDkZj7\nmDBB1lglgYC+NEHZAaObXPzVngAN3fRW7a+IRQLOlYqd8Er0v0jw37R6PjAXFz/5\nFtnX0eMnA0MfNqN9mhKyvgX7mQ
KBgQDcYG4sUOSIO3BG7z9ufL0aiyfERFg6gTJ1\n05xXVNHJBRh+nu6bXPp+a76myiR0QPhXhKuok7PC4opcmreeN4401MGSStgp4Xng\nM/vpMd3knw0zn9DY5FrFdxtIs8YFBcu2XkJzz+rM1IAw563wLRQAuUbb+AOtspZ1\noDZ2ssQk+wKBgE+Oa8xP91sRxHu+KuHIPJtqIJhR1iIp7mPS2iWeH4YTuM11XLjE\nUH5KaoNwZJFBxVAdjT5OyGa9c/l1wz6HFUbL40iBuYKYsAlSK8CpzMUyRnIfYc3v\nsytUN3+sjTlpa1wTDd7WEzZxYm7wQKmORafcOF22+yJ7AX5jzmpBOUSBAoGBAIkY\nLDHBeQoPAAAA4hMX4oRawThl1AVBTmTiacYibAeD9gL/WCyqoOJ4oLgd1KPFrziy\nvh83E4NPbwfA8C2rHfpbyLf7e5JCRJFnhXVCommRUKMm7sOe+6EQQZbuz2dcfahL\n50cot0cJg13pItnhESqKGDzLg25RRSyTqI4bE851AoGAHAixBamIjbFDuSxx9wQ6\n8qy1eB0h66BvZ+YWrXaI6v9zBBSRrdnda35oFVAOFV4LZ6NNsg88ODX/kt9vU5CB\nEmQYAwLLh6vrmw59JifoNIv47GnxGbpCkp9SFhmkiJbyAJiEjAjAtz8HulY1Biqs\nGHkPENC3ZATt4yXI76C5ktU=\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-rcwg7@gil-sample-app.iam.gserviceaccount.com",
+ "client_id": "107121076566697579073",
"auth_uri": "https://accounts.google.com/o/oauth2/auth",
"token_uri": "https://accounts.google.com/o/oauth2/token",
"auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
[07/28] camel git commit: Revert "Changed the alphabetical order of
the modules."
Posted by ac...@apache.org.
Revert "Changed the alphabetical order of the modules."
This reverts commit 0f9b3c977fdc9229b97940ab0de5a0e5a7fcd705.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f3f9575b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f3f9575b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f3f9575b
Branch: refs/heads/master
Commit: f3f9575b90c649426c4724084a66d3d05d1dee8c
Parents: d6dbf5c
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:44 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:44 2016 +0100
----------------------------------------------------------------------
components/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/f3f9575b/components/pom.xml
----------------------------------------------------------------------
diff --git a/components/pom.xml b/components/pom.xml
index ad8a219..bd9e707 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -109,7 +109,6 @@
<module>camel-eventadmin</module>
<module>camel-exec</module>
<module>camel-facebook</module>
- <module>camel-firebase</module>
<module>camel-flatpack</module>
<module>camel-flink</module>
<module>camel-fop</module>
@@ -277,6 +276,7 @@
<module>camel-zipfile</module>
<module>camel-zipkin</module>
<module>camel-zookeeper</module>
+ <module>camel-firebase</module>
</modules>
[23/28] camel git commit: Revert "Fixed style and documentation
issues. The documentation is not yet complete."
Posted by ac...@apache.org.
Revert "Fixed style and documentation issues. The documentation is not yet complete."
This reverts commit cec7b30f3395529dae6dc5b5d46ff0e64cb1d209.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/25dbd0d8
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/25dbd0d8
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/25dbd0d8
Branch: refs/heads/master
Commit: 25dbd0d8ce0ba5d57cb2fc350c8a0b125b7f0b72
Parents: e898247
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:21 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:21 2016 +0100
----------------------------------------------------------------------
.../src/main/docs/firebase-component.adoc | 204 -------------------
.../component/firebase/FirebaseComponent.java | 20 +-
.../component/firebase/FirebaseConfig.java | 26 +--
.../component/firebase/FirebaseConsumer.java | 16 --
.../component/firebase/FirebaseEndpoint.java | 43 +---
.../component/firebase/FirebaseProducer.java | 16 --
.../firebase/data/FirebaseMessage.java | 28 +--
.../component/firebase/data/Operation.java | 16 --
.../exception/DatabaseErrorException.java | 16 --
.../firebase/exception/FirebaseException.java | 47 +++--
.../firebase/FirebaseConsumerDeleteTest.java | 51 ++---
.../firebase/FirebaseConsumerTest.java | 45 ++--
.../firebase/FirebaseProducerTest.java | 42 ++--
.../provider/ConfigurationProvider.java | 25 +--
.../firebase/provider/SampleInputProvider.java | 18 +-
15 files changed, 96 insertions(+), 517 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/docs/firebase-component.adoc
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/docs/firebase-component.adoc b/components/camel-firebase/src/main/docs/firebase-component.adoc
deleted file mode 100644
index e3ca1bb..0000000
--- a/components/camel-firebase/src/main/docs/firebase-component.adoc
+++ /dev/null
@@ -1,204 +0,0 @@
-[[Firebase-FirebaseComponent]]
-Firebase Component
-~~~~~~~~~~~~~~~~~
-
-*Available as of Camel 2.18.x*
-
-The *firebase*�component enables you to save, modify data in Google Firebase database
-and consume to all child of a specific reference.
-
-This component supports producer and event based consumer endpoints.
-
-The Firebase consumer is an event based consumer and can be used to listen
-and respond to five types of Firebase events: add, change, remove, move and cancel�
-
-Maven users will need to add the following dependency to
-their�`pom.xml`�for this component:
-
-[source,xml]
-------------------------------------------------------------
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-firebase</artifactId>
- <version>x.x.x</version>
- <!-- use the same version as your Camel core version -->
-</dependency>
-------------------------------------------------------------
-
-[[Ehcache-URIformat]]
-URI format
-^^^^^^^^^^
-
-[source,java]
------------------------------
-firebase://databaseUrl[?options]
------------------------------
-
-You can append query options to the URI in the following
-format,�`?option=value&option=#beanRef&...`
-
-Do not forget to URL encode the parameters
-
-[[Firebase-Options]]
-Options
-^^^^^^^
-
-
-// component options: START
-The Firebase component has no options.
-// component options: END
-
-
-
-// endpoint options: START
-The Firebase component supports 9 endpoint options which are listed below:
-
-{% raw %}
-[width="100%",cols="2,1,1m,1m,5",options="header"]
-|=======================================================================
-| Name | Group | Default | Java Type | Description
-| databaseUrl | common | | String | *Required* The Firebase database URL. Always uses https
-| async | common | async | boolean | If true the save or update request (set value in Firebase terms) is fired and the reply will be ignored else the routing thread will wait and the reply will be saved in the exchange message
-| keyName | common | firebaseKey | String | The Camel exchange header name in which the Firebase key is specified. Only needed in case you are saving or updating data
-| rootReference | common | | String | *Required* The path in the database tree where the key value pairs are to be stored
-| serviceAccountFile | common | | String | *Required* The path to the JSON file which provided the keys used to connect to Firebase. This file is typically generated when you create the database
-| bridgeErrorHandler | consumer | false | boolean | Allows for bridging the consumer to the Camel routing Error Handler which mean any exceptions occurred while the consumer is trying to pickup incoming messages or the likes will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions that will be logged at WARN/ERROR level and ignored.
-| exceptionHandler | consumer (advanced) | | ExceptionHandler | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this options is not in use. By default the consumer will deal with exceptions that will be logged at WARN/ERROR level and ignored.
-| exchangePattern | consumer (advanced) | | ExchangePattern | Sets the exchange pattern when the consumer creates an exchange.
-| synchronous | advanced | false | boolean | Sets whether synchronous processing should be strictly used or Camel is allowed to use asynchronous processing (if supported).
-|=======================================================================
-{% endraw %}
-// endpoint options: END
-
-
-[[Ehcache-MessageHeadersCamel]]
-Message Headers Camel�
-++++++++++++++++++++++
-
-�
-[width="100%",cols="10%,10%,80%",options="header",]
-|=======================================================================
-|Header |Type |Description
-
-|CamelEhcacheAction |`String` |The operation to be perfomed on the cache, valid options are:
-
-* CLEAR
-* PUT
-* PUT_ALL
-* PUT_IF_ABSENT
-* GET
-* GET_ALL
-* REMOVE
-* REMOVE_ALL
-* REPLACE
-
-|CamelEhcacheActionHasResult |Boolean |Set to true if the action has a result
-
-|CamelEhcacheActionSucceeded |`Boolean` |Set to true if the actionsuccedded
-
-|CamelEhcacheKey |Object |The cache key used for an action
-
-|CamelEhcacheKeys |Set<Object> |A list of keys, used in
-
-* PUT_ALL
-* GET_ALL
-* REMOVE_ALL
-
-|CamelEhcacheValue |Object |The value to put in the cache or the result of an operation
-
-|CamelEhcacheOldValue |Object |The old value associated to a key for actions like PUT_IF_ABSENT or the
-Object used for comparison for actions like REPLACE
-
-|CamelEhcacheEventType |EventType |The type of event received
-|=======================================================================
-
-[[Ehcache-Ehcachebasedidempotentrepositoryexample:]]
-Ehcache based idempotent repository example:
-^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
-
-[source,java]
-------------------------------------------------------------------------------------------------
-CacheManager manager = CacheManagerBuilder.newCacheManager(new XmlConfiguration("ehcache.xml"));
-EhcacheIdempotentRepository repo = new EhcacheIdempotentRepository(manager, "idempotent-cache");
-
-from("direct:in")
- .idempotentConsumer(header("messageId"), idempotentRepo)
- .to("mock:out");
-------------------------------------------------------------------------------------------------
-
-�
-
-[[Ehcache-Ehcachebasedaggregationrepositoryexample:]]
-Ehcache based aggregation repository example:
-^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
-
-[source,java]
----------------------------------------------------------------------------------------------------------------------------------
-public class EhcacheAggregationRepositoryRoutesTest extends CamelTestSupport {
- private static final String ENDPOINT_MOCK = "mock:result";
- private static final String ENDPOINT_DIRECT = "direct:one";
- private static final int[] VALUES = generateRandomArrayOfInt(10, 0, 30);
- private static final int SUM = IntStream.of(VALUES).reduce(0, (a, b) -> a + b);
- private static final String CORRELATOR = "CORRELATOR";
-
- @EndpointInject(uri = ENDPOINT_MOCK)
- private MockEndpoint mock;
-
- @Produce(uri = ENDPOINT_DIRECT)
- private ProducerTemplate producer;
-
- @Test
- public void checkAggregationFromOneRoute() throws Exception {
- mock.expectedMessageCount(VALUES.length);
- mock.expectedBodiesReceived(SUM);
-
- IntStream.of(VALUES).forEach(
- i -> producer.sendBodyAndHeader(i, CORRELATOR, CORRELATOR)
- );
-
- mock.assertIsSatisfied();
- }
-
- private Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
- if (oldExchange == null) {
- return newExchange;
- } else {
- Integer n = newExchange.getIn().getBody(Integer.class);
- Integer o = oldExchange.getIn().getBody(Integer.class);
- Integer v = (o == null ? 0 : o) + (n == null ? 0 : n);
-
- oldExchange.getIn().setBody(v, Integer.class);
-
- return oldExchange;
- }
- }
-
- @Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- from(ENDPOINT_DIRECT)
- .routeId("AggregatingRouteOne")
- .aggregate(header(CORRELATOR))
- .aggregationRepository(createAggregateRepository())
- .aggregationStrategy(EhcacheAggregationRepositoryRoutesTest.this::aggregate)
- .completionSize(VALUES.length)
- .to("log:org.apache.camel.component.ehcache.processor.aggregate.level=INFO&showAll=true&mulltiline=true")
- .to(ENDPOINT_MOCK);
- }
- };
- }
-
- protected EhcacheAggregationRepository createAggregateRepository() throws Exception {
- CacheManager cacheManager = CacheManagerBuilder.newCacheManager(new XmlConfiguration("ehcache.xml"));
- cacheManager.init();
-
- EhcacheAggregationRepository repository = new EhcacheAggregationRepository();
- repository.setCacheManager(cacheManager);
- repository.setCacheName("aggregate");
-
- return repository;
- }
-}
----------------------------------------------------------------------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
index 8b80a2a..18e6d64 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
@@ -1,27 +1,11 @@
-/**
- * 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.firebase;
-import java.util.Map;
-
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.impl.UriEndpointComponent;
+import java.util.Map;
+
/**
* Represents the component that manages {@link FirebaseEndpoint}.
*/
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java
index 7f6641e..a46caf8 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConfig.java
@@ -1,34 +1,18 @@
-/**
- * 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.firebase;
+import com.google.firebase.FirebaseApp;
+import com.google.firebase.FirebaseOptions;
+
import java.io.IOException;
import java.io.InputStream;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.UUID;
-import com.google.firebase.FirebaseApp;
-import com.google.firebase.FirebaseOptions;
-
/**
* Contains the elements needed to connect to Firebase
*/
-public final class FirebaseConfig {
+public class FirebaseConfig {
private final String databaseUrl;
@@ -51,7 +35,7 @@ public final class FirebaseConfig {
}
public void init() throws IOException {
- try (InputStream in = Files.newInputStream(Paths.get(serviceAccountFile))) {
+ try(InputStream in = Files.newInputStream(Paths.get(serviceAccountFile))) {
FirebaseOptions options = new FirebaseOptions.Builder()
.setServiceAccount(in)
.setDatabaseUrl(this.databaseUrl)
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
index bbcb2b6..1dee1a4 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
@@ -1,19 +1,3 @@
-/**
- * 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.firebase;
import com.google.firebase.database.ChildEventListener;
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
index a6b035b..0be796a 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
@@ -1,19 +1,3 @@
-/**
- * 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.firebase;
import com.google.firebase.FirebaseApp;
@@ -24,37 +8,27 @@ import org.apache.camel.impl.DefaultEndpoint;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
-import org.apache.camel.spi.UriPath;
/**
* Represents a Firebase endpoint.
*/
-@UriEndpoint(scheme = "firebase", title = "Firebase", syntax = "firebase:name", consumerClass = FirebaseConsumer.class, label = "Firebase")
+@UriEndpoint(scheme = "firebase", title = "Firebase", syntax="firebase:name", consumerClass = FirebaseConsumer.class, label = "Firebase")
public class FirebaseEndpoint extends DefaultEndpoint {
private final FirebaseConfig firebaseConfig;
- @UriPath(description = "The Firebase database URL. Always uses https")
- @Metadata(required = "true")
- private String databaseUrl;
-
- @UriParam(description = "The path in the database tree where the key value pairs are to be stored")
+ @UriParam
@Metadata(required = "true")
private String rootReference;
- @UriParam(description = "The path to the JSON file which provided the keys used to connect to Firebase. #"
- + "This file is typically generated when you create the database")
+ @UriParam
@Metadata(required = "true")
private String serviceAccountFile;
- @UriParam(defaultValue = "firebaseKey", description = "The Camel exchange header name in which "
- + "the Firebase key is specified. Only needed in case you are saving or updating data")
- @Metadata(required = "false")
+ @UriParam(defaultValue = "firebaseKey") @Metadata(required = "false")
private String keyName = "firebaseKey";
- @UriParam(defaultValue = "async", description = "If true, the save or update request (set value in Firebase terms) "
- + "is fired and the reply will be ignored, else the routing thread will wait and the reply will be saved in the exchange message")
- @Metadata(required = "false")
+ @UriParam(defaultValue = "async") @Metadata(required = "false")
private boolean async;
public FirebaseEndpoint(String uri, FirebaseComponent firebaseComponent, FirebaseConfig firebaseConfig) {
@@ -62,10 +36,9 @@ public class FirebaseEndpoint extends DefaultEndpoint {
this.firebaseConfig = firebaseConfig;
this.setRootReference(firebaseConfig.getRootReference());
this.setServiceAccountFile(firebaseConfig.getServiceAccountFile());
- this.databaseUrl = firebaseConfig.getDatabaseUrl();
final String keyName = firebaseConfig.getKeyName();
this.setAsync(firebaseConfig.isAsync());
- if (keyName != null) {
+ if(keyName != null) {
this.setKeyName(keyName);
}
}
@@ -121,8 +94,4 @@ public class FirebaseEndpoint extends DefaultEndpoint {
public FirebaseApp getFirebaseApp() {
return firebaseConfig.getFirebaseApp();
}
-
- public String getDatabaseUrl() {
- return databaseUrl;
- }
}
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
index ef8f8a6..bc09550 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
@@ -1,19 +1,3 @@
-/**
- * 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.firebase;
import com.google.firebase.database.DatabaseError;
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
index 4999102..afd02ae 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/FirebaseMessage.java
@@ -1,19 +1,3 @@
-/**
- * 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.firebase.data;
import com.google.firebase.database.DataSnapshot;
@@ -22,7 +6,7 @@ import com.google.firebase.database.DatabaseError;
/**
* Contains a message sent by Firebase.
*/
-public final class FirebaseMessage {
+public class FirebaseMessage {
private final Operation operation;
@@ -57,11 +41,11 @@ public final class FirebaseMessage {
@Override
public String toString() {
- return "FirebaseMessage{"
- + "operation=" + operation
- + ", dataSnapshot=" + dataSnapshot
- + ", previousChildName='" + previousChildName + '\''
- + ", databaseError=" + databaseError + '}';
+ return "FirebaseMessage{" + "operation=" + operation +
+ ", dataSnapshot=" + dataSnapshot +
+ ", previousChildName='" + previousChildName + '\'' +
+ ", databaseError=" + databaseError +
+ '}';
}
public static class Builder {
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java
index 609a209..5410c61 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/data/Operation.java
@@ -1,19 +1,3 @@
-/**
- * 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.firebase.data;
/**
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java
index a7939e2..4c2d23e 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/DatabaseErrorException.java
@@ -1,19 +1,3 @@
-/**
- * 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.firebase.exception;
import com.google.firebase.database.DatabaseError;
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
index a39b871..190f386 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
@@ -1,26 +1,34 @@
-/**
- * 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.firebase.exception;
+import com.google.firebase.database.DatabaseError;
+
/**
* Used to mark an exception occurred in the Firebase Camel processor.
*/
public class FirebaseException extends RuntimeException {
+ private DatabaseError databaseError;
+
+ /**
+ * Constructs a new runtime exception with {@code null} as its
+ * detail message. The cause is not initialized, and may subsequently be
+ * initialized by a call to {@link #initCause}.
+ */
+ public FirebaseException() {
+ }
+
+ /**
+ * Constructs a new runtime exception with the specified detail message.
+ * The cause is not initialized, and may subsequently be initialized by a
+ * call to {@link #initCause}.
+ *
+ * @param message the detail message. The detail message is saved for
+ * later retrieval by the {@link #getMessage()} method.
+ */
+ public FirebaseException(String message) {
+ super(message);
+ }
+
/**
* Constructs a new runtime exception with the specified detail message and
* cause. <p>Note that the detail message associated with
@@ -39,4 +47,11 @@ public class FirebaseException extends RuntimeException {
super(message, cause);
}
+ public void setDatabaseError(DatabaseError databaseError) {
+ this.databaseError = databaseError;
+ }
+
+ public DatabaseError getDatabaseError() {
+ return databaseError;
+ }
}
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java
index f3600e9..460a7e7 100644
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java
+++ b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerDeleteTest.java
@@ -1,27 +1,5 @@
-/**
- * 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.firebase;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.locks.Condition;
-import java.util.concurrent.locks.ReentrantLock;
-
-import static junit.framework.TestCase.fail;
-
import com.google.firebase.database.DatabaseReference;
import com.google.firebase.database.FirebaseDatabase;
import org.apache.camel.CamelContext;
@@ -33,8 +11,12 @@ import org.apache.camel.component.firebase.provider.SampleInputProvider;
import org.apache.camel.impl.DefaultCamelContext;
import org.junit.Test;
-import static org.assertj.core.api.Assertions.assertThat;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.ReentrantLock;
+import static junit.framework.TestCase.fail;
+import static org.assertj.core.api.Assertions.assertThat;
/**
* Starts a route which listens to the remove event in Firebase. It then writes and deletes an entry in Firebase and
@@ -47,13 +29,15 @@ public class FirebaseConsumerDeleteTest {
private final Condition wake = reentrantLock.newCondition();
@Test
- public void whenDeleteDeleteMessageShouldBeIntercepted() throws Exception {
+ public void whenDelete_DeleteMessageShouldBeIntercepted() throws Exception {
CamelContext context = new DefaultCamelContext();
- boolean[] deleteMessageReceived = {false};
+ boolean[] deleteMessageReceived = { false };
FirebaseConfig firebaseConfig = ConfigurationProvider.createDemoConfig();
- createAndDeleteContent(firebaseConfig, false);
setupRoute(context, deleteMessageReceived);
-
+ context.addStartupListener((context1, alreadyStarted) -> {
+ TimeUnit.SECONDS.sleep(5);
+ createAndDeleteContent(firebaseConfig);
+ });
context.start();
try {
reentrantLock.lock();
@@ -65,19 +49,16 @@ public class FirebaseConsumerDeleteTest {
context.stop();
}
- private void createAndDeleteContent(FirebaseConfig firebaseConfig, boolean delete) {
+ private void createAndDeleteContent(FirebaseConfig firebaseConfig) {
final DatabaseReference rootReference = FirebaseDatabase.getInstance(firebaseConfig.getFirebaseApp())
.getReference(ConfigurationProvider.createRootReference()).child(SampleInputProvider.createDeleteKey());
rootReference
.setValue("AETHELWULF 839-856", (databaseError, databaseReference) -> {
- if (delete) {
- databaseReference.removeValue();
- }
+ databaseReference.removeValue();
});
}
private void setupRoute(CamelContext context, final boolean[] deleteMessageReceived) throws Exception {
- boolean deleteFired[] = {false};
context.addRoutes(new RouteBuilder() {
public void configure() {
try {
@@ -94,12 +75,6 @@ public class FirebaseConsumerDeleteTest {
} finally {
reentrantLock.unlock();
}
- } else {
- if (!deleteFired[0]) {
- deleteFired[0] = true;
- FirebaseConfig firebaseConfig = ConfigurationProvider.createDemoConfig();
- createAndDeleteContent(firebaseConfig, true);
- }
}
});
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java
index 8395a98..2c6cbc4 100644
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java
+++ b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseConsumerTest.java
@@ -1,28 +1,5 @@
-/**
- * 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.firebase;
-
-import java.io.IOException;
-import java.net.URLDecoder;
-import java.net.URLEncoder;
-import java.util.concurrent.locks.Condition;
-import java.util.concurrent.locks.ReentrantLock;
-
import com.google.firebase.database.FirebaseDatabase;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.firebase.provider.ConfigurationProvider;
@@ -30,17 +7,19 @@ import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;
+import java.io.IOException;
+import java.net.URLDecoder;
+import java.net.URLEncoder;
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.ReentrantLock;
+
/**
* Writes a dummy message and then checks, if the consumer receives at least one message.
*/
public class FirebaseConsumerTest extends CamelTestSupport {
- private final ReentrantLock lock = new ReentrantLock();
-
- private final Condition wake = lock.newCondition();
-
@Test
- public void whenFirebaseListenerShouldReceiveMessages() throws Exception {
+ public void whenFirebaseListener_ShouldReceiveMessages() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMinimumMessageCount(1);
assertMockEndpointsSatisfied();
@@ -68,6 +47,10 @@ public class FirebaseConsumerTest extends CamelTestSupport {
};
}
+ private final ReentrantLock lock = new ReentrantLock();
+
+ private final Condition wake = lock.newCondition();
+
private void insertDummyData(String databaseUrl, String originalRootReference, String serviceAccountFile) throws IOException, InterruptedException {
FirebaseConfig config = new FirebaseConfig.Builder(databaseUrl, originalRootReference, URLDecoder.decode(serviceAccountFile, "UTF-8"))
.build();
@@ -78,14 +61,16 @@ public class FirebaseConsumerTest extends CamelTestSupport {
try {
lock.lock();
wake.signal();
- } finally {
+ }
+ finally {
lock.unlock();
}
});
try {
lock.lock();
wake.await();
- } finally {
+ }
+ finally {
lock.unlock();
}
}
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
index f0f2cc3..549bfef 100644
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
+++ b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
@@ -1,27 +1,5 @@
-/**
- * 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.firebase;
-import java.net.URLEncoder;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.util.concurrent.locks.Condition;
-import java.util.concurrent.locks.ReentrantLock;
-
import com.google.firebase.database.DatabaseReference;
import org.apache.camel.CamelContext;
import org.apache.camel.Message;
@@ -33,6 +11,12 @@ import org.apache.camel.impl.DefaultCamelContext;
import org.junit.Before;
import org.junit.Test;
+import java.net.URLEncoder;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.ReentrantLock;
+
import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
/**
@@ -52,12 +36,12 @@ public class FirebaseProducerTest {
}
@Test
- public void whenFirebaseSetShouldReceiveMessagesSync() throws Exception {
+ public void whenFirebaseSet_ShouldReceiveMessagesSync() throws Exception {
startRoute(false, DatabaseReference.class);
}
@Test
- public void whenFirebaseSetShouldReceiveMessagesAsync() throws Exception {
+ public void whenFirebaseSet_ShouldReceiveMessagesAsync() throws Exception {
startRoute(true, String.class);
}
@@ -83,20 +67,22 @@ public class FirebaseProducerTest {
.to("log:whenFirebaseSet?level=WARN")
.process(exchange1 -> {
assertThat(exchange1.getIn().getBody().getClass()).isEqualTo(expectedBodyClass);
- try {
+ try{
reentrantLock.lock();
wake.signal();
- } finally {
+ }
+ finally {
reentrantLock.unlock();
}
});
}
});
context.start();
- try {
+ try{
reentrantLock.lock();
wake.await();
- } finally {
+ }
+ finally {
reentrantLock.unlock();
}
context.stop();
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
index 6b6a51f..d33d881 100644
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
+++ b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/ConfigurationProvider.java
@@ -1,21 +1,7 @@
-/**
- * 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.firebase.provider;
+import org.apache.camel.component.firebase.FirebaseConfig;
+
import java.io.File;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
@@ -24,17 +10,12 @@ import java.net.URL;
import java.net.URLDecoder;
import java.net.URLEncoder;
-import org.apache.camel.component.firebase.FirebaseConfig;
-
import static org.junit.Assert.assertNotNull;
/**
* Provides the path of the configuration used to access Firebase.
*/
-public final class ConfigurationProvider {
-
- private ConfigurationProvider() {
- }
+public class ConfigurationProvider {
public static String createFirebaseConfigLink() throws URISyntaxException, UnsupportedEncodingException {
URL url = Thread.currentThread().getContextClassLoader().getResource("firebase-admin-connection.json");
http://git-wip-us.apache.org/repos/asf/camel/blob/25dbd0d8/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java
index 38477ef..4b0d4f7 100644
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java
+++ b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/provider/SampleInputProvider.java
@@ -1,19 +1,3 @@
-/**
- * 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.firebase.provider;
import java.io.IOException;
@@ -36,7 +20,7 @@ public class SampleInputProvider {
public SampleInputProvider() throws IOException {
targetFolder = Paths.get("src/data");
- if (!Files.exists(targetFolder)) {
+ if(!Files.exists(targetFolder)) {
Files.createDirectories(targetFolder);
}
}
[03/28] camel git commit: Revert "Camel-Firebase: Added component doc"
Posted by ac...@apache.org.
Revert "Camel-Firebase: Added component doc"
This reverts commit e888e8d176288fa05c1310328853dea379bda0ec.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/96b44a3d
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/96b44a3d
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/96b44a3d
Branch: refs/heads/master
Commit: 96b44a3d7fcd36813a03449a8a1650d10761d4ad
Parents: 09d212e
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:33 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:33 2016 +0100
----------------------------------------------------------------------
components/camel-firebase/src/main/docs/firebase-component.adoc | 4 ----
1 file changed, 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/96b44a3d/components/camel-firebase/src/main/docs/firebase-component.adoc
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/docs/firebase-component.adoc b/components/camel-firebase/src/main/docs/firebase-component.adoc
index 9b2daeb..29c912b 100644
--- a/components/camel-firebase/src/main/docs/firebase-component.adoc
+++ b/components/camel-firebase/src/main/docs/firebase-component.adoc
@@ -43,10 +43,6 @@ Do not forget to URL encode the option values.
Options
^^^^^^^
-// component options: START
-The Firebase component has no options.
-// component options: END
-
// endpoint options: START
The Firebase component supports 9 endpoint options which are listed below:
[19/28] camel git commit: Revert "Changed the UriEndpoint annotation
with the values suggested by davsclaus."
Posted by ac...@apache.org.
Revert "Changed the UriEndpoint annotation with the values suggested by davsclaus."
This reverts commit e61448cb0e7f2698d1b7bceba2a9d46b1f98cbe8.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c1c7a701
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c1c7a701
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c1c7a701
Branch: refs/heads/master
Commit: c1c7a70143f8fa3bb161512e737c07173e90d86f
Parents: 6687005
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:12 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:12 2016 +0100
----------------------------------------------------------------------
.../java/org/apache/camel/component/firebase/FirebaseEndpoint.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/c1c7a701/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
index 709785e..a6b035b 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.spi.UriPath;
/**
* Represents a Firebase endpoint.
*/
-@UriEndpoint(scheme = "firebase", title = "Firebase", syntax = "firebase:databaseUrl", consumerClass = FirebaseConsumer.class, label = "cloud,messaging")
+@UriEndpoint(scheme = "firebase", title = "Firebase", syntax = "firebase:name", consumerClass = FirebaseConsumer.class, label = "Firebase")
public class FirebaseEndpoint extends DefaultEndpoint {
private final FirebaseConfig firebaseConfig;
[11/28] camel git commit: Revert "Added first version of the
documentation which should be complete."
Posted by ac...@apache.org.
Revert "Added first version of the documentation which should be complete."
This reverts commit 0624507966ea9a6c53c0e0c14c19b77ec548e217.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/827fd43d
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/827fd43d
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/827fd43d
Branch: refs/heads/master
Commit: 827fd43d7c2213db6f5c31db7021d3de5d04df7b
Parents: 93291ec
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:53 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:53 2016 +0100
----------------------------------------------------------------------
.../src/main/docs/firebase-component.adoc | 220 +++++++++++--------
1 file changed, 131 insertions(+), 89 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/827fd43d/components/camel-firebase/src/main/docs/firebase-component.adoc
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/docs/firebase-component.adoc b/components/camel-firebase/src/main/docs/firebase-component.adoc
index c0701cf..e3ca1bb 100644
--- a/components/camel-firebase/src/main/docs/firebase-component.adoc
+++ b/components/camel-firebase/src/main/docs/firebase-component.adoc
@@ -2,7 +2,7 @@
Firebase Component
~~~~~~~~~~~~~~~~~
-*Available as of Camel 2.19.x*
+*Available as of Camel 2.18.x*
The *firebase*�component enables you to save, modify data in Google Firebase database
and consume to all child of a specific reference.
@@ -25,32 +25,41 @@ their�`pom.xml`�for this component:
</dependency>
------------------------------------------------------------
-[[Firebase-URIformat]]
+[[Ehcache-URIformat]]
URI format
^^^^^^^^^^
[source,java]
-----------------------------
-firebase://[endpoint]?[options]
+firebase://databaseUrl[?options]
-----------------------------
You can append query options to the URI in the following
-format,�`?option=value&option=value1&...`
+format,�`?option=value&option=#beanRef&...`
-Do not forget to URL encode the option values.
+Do not forget to URL encode the parameters
[[Firebase-Options]]
Options
^^^^^^^
+
+// component options: START
+The Firebase component has no options.
+// component options: END
+
+
+
// endpoint options: START
The Firebase component supports 9 endpoint options which are listed below:
+{% raw %}
[width="100%",cols="2,1,1m,1m,5",options="header"]
|=======================================================================
| Name | Group | Default | Java Type | Description
+| databaseUrl | common | | String | *Required* The Firebase database URL. Always uses https
+| async | common | async | boolean | If true the save or update request (set value in Firebase terms) is fired and the reply will be ignored else the routing thread will wait and the reply will be saved in the exchange message
| keyName | common | firebaseKey | String | The Camel exchange header name in which the Firebase key is specified. Only needed in case you are saving or updating data
-| reply | common | false | boolean | If *false* the save or update request (*setValue* in Firebase terms) is fired and the reply will be ignored, otherwise the routing thread will wait and the reply will be saved in the body of the exchange message
| rootReference | common | | String | *Required* The path in the database tree where the key value pairs are to be stored
| serviceAccountFile | common | | String | *Required* The path to the JSON file which provided the keys used to connect to Firebase. This file is typically generated when you create the database
| bridgeErrorHandler | consumer | false | boolean | Allows for bridging the consumer to the Camel routing Error Handler which mean any exceptions occurred while the consumer is trying to pickup incoming messages or the likes will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions that will be logged at WARN/ERROR level and ignored.
@@ -58,105 +67,138 @@ The Firebase component supports 9 endpoint options which are listed below:
| exchangePattern | consumer (advanced) | | ExchangePattern | Sets the exchange pattern when the consumer creates an exchange.
| synchronous | advanced | false | boolean | Sets whether synchronous processing should be strictly used or Camel is allowed to use asynchronous processing (if supported).
|=======================================================================
+{% endraw %}
// endpoint options: END
-[[Firebase-MessageHeadersCamel]]
+[[Ehcache-MessageHeadersCamel]]
Message Headers Camel�
++++++++++++++++++++++
-
-[width="100%",cols="20%,10%,70%",options="header"]
-|=======================================================================
-| Header | Type | Description
-| firebaseKey | `String` | The Firebase key to which a child listener is attached. This name of this parameter can be overriden using the *firebaseKey* option
+�
+[width="100%",cols="10%,10%,80%",options="header",]
|=======================================================================
+|Header |Type |Description
+
+|CamelEhcacheAction |`String` |The operation to be perfomed on the cache, valid options are:
+
+* CLEAR
+* PUT
+* PUT_ALL
+* PUT_IF_ABSENT
+* GET
+* GET_ALL
+* REMOVE
+* REMOVE_ALL
+* REPLACE
-[[Firebase-Usageexamples]]
+|CamelEhcacheActionHasResult |Boolean |Set to true if the action has a result
-Usage examples
-^^^^^^^^^^^^^^
+|CamelEhcacheActionSucceeded |`Boolean` |Set to true if the actionsuccedded
-[[Firebase-Consumer]]
-Firebase Consumer
-+++++++++++++++++
+|CamelEhcacheKey |Object |The cache key used for an action
-The code below demonstrates how you can create a route which consumes the messages coming from a Firebase listener.
+|CamelEhcacheKeys |Set<Object> |A list of keys, used in
+
+* PUT_ALL
+* GET_ALL
+* REMOVE_ALL
+
+|CamelEhcacheValue |Object |The value to put in the cache or the result of an operation
+
+|CamelEhcacheOldValue |Object |The old value associated to a key for actions like PUT_IF_ABSENT or the
+Object used for comparison for actions like REPLACE
+
+|CamelEhcacheEventType |EventType |The type of event received
+|=======================================================================
+
+[[Ehcache-Ehcachebasedidempotentrepositoryexample:]]
+Ehcache based idempotent repository example:
+^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[source,java]
---------------------------------------------------------------------------------------
-@Override
-protected RouteBuilder createRouteBuilder() throws Exception {
- final String databaseUrl = "gil-sample-app.firebaseio.com";
- final String originalRootReference = "server/saving-data";
- String serviceAccountFile = ConfigurationProvider.createFirebaseConfigLink();
- String rootReference = URLEncoder.encode(originalRootReference, "UTF-8");
- insertDummyData(String.format("https://%s", databaseUrl), originalRootReference, serviceAccountFile);
-
- return new RouteBuilder() {
- public void configure() {
- try {
- from(String.format("firebase://" + databaseUrl + "?rootReference=%s&serviceAccountFile=%s",
- rootReference, serviceAccountFile))
- .to("log:firebasetest?level=WARN")
- .to("mock:result");
- } catch (Exception e) {
- fail(e.toString());
- }
- }
- };
-}
---------------------------------------------------------------------------------------
+------------------------------------------------------------------------------------------------
+CacheManager manager = CacheManagerBuilder.newCacheManager(new XmlConfiguration("ehcache.xml"));
+EhcacheIdempotentRepository repo = new EhcacheIdempotentRepository(manager, "idempotent-cache");
+
+from("direct:in")
+ .idempotentConsumer(header("messageId"), idempotentRepo)
+ .to("mock:out");
+------------------------------------------------------------------------------------------------
-[[Firebase-Producer]]
-Firebase Producer
-+++++++++++++++++
+�
-The example below shows how you can send data to Firebase.
+[[Ehcache-Ehcachebasedaggregationrepositoryexample:]]
+Ehcache based aggregation repository example:
+^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[source,java]
---------------------------------------
-CamelContext context = new DefaultCamelContext();
-context.addRoutes(new RouteBuilder() {
+---------------------------------------------------------------------------------------------------------------------------------
+public class EhcacheAggregationRepositoryRoutesTest extends CamelTestSupport {
+ private static final String ENDPOINT_MOCK = "mock:result";
+ private static final String ENDPOINT_DIRECT = "direct:one";
+ private static final int[] VALUES = generateRandomArrayOfInt(10, 0, 30);
+ private static final int SUM = IntStream.of(VALUES).reduce(0, (a, b) -> a + b);
+ private static final String CORRELATOR = "CORRELATOR";
+
+ @EndpointInject(uri = ENDPOINT_MOCK)
+ private MockEndpoint mock;
+
+ @Produce(uri = ENDPOINT_DIRECT)
+ private ProducerTemplate producer;
+
+ @Test
+ public void checkAggregationFromOneRoute() throws Exception {
+ mock.expectedMessageCount(VALUES.length);
+ mock.expectedBodiesReceived(SUM);
+
+ IntStream.of(VALUES).forEach(
+ i -> producer.sendBodyAndHeader(i, CORRELATOR, CORRELATOR)
+ );
+
+ mock.assertIsSatisfied();
+ }
+
+ private Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
+ if (oldExchange == null) {
+ return newExchange;
+ } else {
+ Integer n = newExchange.getIn().getBody(Integer.class);
+ Integer o = oldExchange.getIn().getBody(Integer.class);
+ Integer v = (o == null ? 0 : o) + (n == null ? 0 : n);
+
+ oldExchange.getIn().setBody(v, Integer.class);
+
+ return oldExchange;
+ }
+ }
+
@Override
- public void configure() throws Exception {
- String rootReference = URLEncoder.encode("server/saving-data", "UTF-8");
- String serviceAccountFile = "firebase-admin-connection.json";
- from(sampleInputProvider.getTargetFolder().toUri().toString())
- .process(exchange -> {
- GenericFile file = (GenericFile) exchange.getIn().getBody();
- String content = new String(Files.readAllBytes(Paths.get(file.getAbsoluteFilePath())), "UTF-8");
- String[] keyValue = content.split("=");
- final Message out = exchange.getOut();
- out.setHeader("firebaseKey", keyValue[0]);
- out.setBody(keyValue[1].trim());
- })
- .to(String.format("firebase://%s?rootReference=%s&serviceAccountFile=%s&reply=%b",
- "gil-sample-app.firebaseio.com", rootReference, serviceAccountFile, reply))
- .to("log:whenFirebaseSet?level=WARN")
- .process(exchange1 -> {
- assertThat(exchange1.getIn().getBody().getClass()).isEqualTo(expectedBodyClass);
- if (reply) {
- assertThat(exchange1.getIn().getHeader("firebaseKey")).isNotNull();
- }
- try {
- reentrantLock.lock();
- wake.signal();
- } finally {
- reentrantLock.unlock();
- }
- });
+ protected RoutesBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from(ENDPOINT_DIRECT)
+ .routeId("AggregatingRouteOne")
+ .aggregate(header(CORRELATOR))
+ .aggregationRepository(createAggregateRepository())
+ .aggregationStrategy(EhcacheAggregationRepositoryRoutesTest.this::aggregate)
+ .completionSize(VALUES.length)
+ .to("log:org.apache.camel.component.ehcache.processor.aggregate.level=INFO&showAll=true&mulltiline=true")
+ .to(ENDPOINT_MOCK);
+ }
+ };
}
-});
---------------------------------------
-
-[[Exec-SeeAlso]]
-See Also
-^^^^^^^^
-
-* link:configuring-camel.html[Configuring Camel]
-* link:component.html[Component]
-* link:endpoint.html[Endpoint]
-* link:getting-started.html[Getting Started]
-* link:https://firebase.google.com/[Firebase]
-* link:https://console.firebase.google.com/[Firebase console]
\ No newline at end of file
+
+ protected EhcacheAggregationRepository createAggregateRepository() throws Exception {
+ CacheManager cacheManager = CacheManagerBuilder.newCacheManager(new XmlConfiguration("ehcache.xml"));
+ cacheManager.init();
+
+ EhcacheAggregationRepository repository = new EhcacheAggregationRepository();
+ repository.setCacheManager(cacheManager);
+ repository.setCacheName("aggregate");
+
+ return repository;
+ }
+}
+---------------------------------------------------------------------------------------------------------------------------------
[25/28] camel git commit: Revert "Renamed the Firebase admin
configuration file."
Posted by ac...@apache.org.
Revert "Renamed the Firebase admin configuration file."
This reverts commit ac2283fa196b8a56d9e764a091ff3956e9b479a3.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ced32a87
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ced32a87
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ced32a87
Branch: refs/heads/master
Commit: ced32a87ea831ffd88a9a5dae05edb86bcafab36
Parents: c711294
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:33 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:33 2016 +0100
----------------------------------------------------------------------
.../src/test/resources/firebase-admin-connection.json | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/ced32a87/components/camel-firebase/src/test/resources/firebase-admin-connection.json
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/firebase-admin-connection.json b/components/camel-firebase/src/test/resources/firebase-admin-connection.json
index 7a9f352..69feae7 100644
--- a/components/camel-firebase/src/test/resources/firebase-admin-connection.json
+++ b/components/camel-firebase/src/test/resources/firebase-admin-connection.json
@@ -1,9 +1,9 @@
{
"type": "service_account",
"project_id": "gil-sample-app",
- "private_key_id": "fea519a672d21f7667afb1badbeb858342ae32ac",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDX88p2HcAn2z0t\n7uAk0jB0RUyi4f+SWd3ofM6Ju59XLyttnbXKEYNBnjIE3YOJ49Xd92vFXGsYU+DU\nb7vFf/rXtfiZglE6zHF8p+53Jy/AJKWHLWKa+nZa4vUQASmBGJy5SF37YJhaE/Mu\nUqNESdZowdjro4bE3D/VYZsK/9UmHEO8PmlKL9Igl4WVq5I1toJk1eae/2nBmE3+\n3/uGrTf6ydJ8xx/tPMwWGLRNYxb4PQliTTCaLc5dR/p9B8YMwMtuxWU9IereIKp8\n51ZgYW6e/6IHbfb22cp2NwKHxwvnZu5HZ1+IIZ+3n9S2OJYZGPBIB7xJzSd6xXAf\nXAQqYzMDAgMBAAECggEAYfbEJ6UDYJFCRa4RnGKFfJlbVKC1MYz279p+T1j/xasu\nRkG/D/W113SOOErMuybSBCmTiCqOorCaU4SEZ+nQvz5bkjfd5ZCNAwGjWgY60S1O\nse3Sx39LZZuDlEkSrO+fWSYNDFYbhvF55c+zJO1iCI+3ed3q6y8G/iOTFABOj0R5\nZ7pPJqzXIg3sKRaMOJ+l2F8/nIZ8AUyesByJgP4UuyYTb9LaqRqIz/URYh2xVohW\n3MkXmCDkY5tyzJ7rwJloHoOo4Hsvefzgv3dDJYu4FJ7BUHFyNa6yZDGdte49WQsS\nDNEwEDvBPsE00olbsjAkSpdC0u57836Vn81Xz84y4QKBgQD63EWzFrVx0w+8PSy8\nPqZgQWEwHb09r2c9TjaxqohtapqFZZ5szEiOOad8r369RQ6bVIMzYzYRBUGDkZj7\nmDBB1lglgYC+NEHZAaObXPzVngAN3fRW7a+IRQLOlYqd8Er0v0jw37R6PjAXFz/5\nFtnX0eMnA0MfNqN9mhKyvgX7mQ
KBgQDcYG4sUOSIO3BG7z9ufL0aiyfERFg6gTJ1\n05xXVNHJBRh+nu6bXPp+a76myiR0QPhXhKuok7PC4opcmreeN4401MGSStgp4Xng\nM/vpMd3knw0zn9DY5FrFdxtIs8YFBcu2XkJzz+rM1IAw563wLRQAuUbb+AOtspZ1\noDZ2ssQk+wKBgE+Oa8xP91sRxHu+KuHIPJtqIJhR1iIp7mPS2iWeH4YTuM11XLjE\nUH5KaoNwZJFBxVAdjT5OyGa9c/l1wz6HFUbL40iBuYKYsAlSK8CpzMUyRnIfYc3v\nsytUN3+sjTlpa1wTDd7WEzZxYm7wQKmORafcOF22+yJ7AX5jzmpBOUSBAoGBAIkY\nLDHBeQoPAAAA4hMX4oRawThl1AVBTmTiacYibAeD9gL/WCyqoOJ4oLgd1KPFrziy\nvh83E4NPbwfA8C2rHfpbyLf7e5JCRJFnhXVCommRUKMm7sOe+6EQQZbuz2dcfahL\n50cot0cJg13pItnhESqKGDzLg25RRSyTqI4bE851AoGAHAixBamIjbFDuSxx9wQ6\n8qy1eB0h66BvZ+YWrXaI6v9zBBSRrdnda35oFVAOFV4LZ6NNsg88ODX/kt9vU5CB\nEmQYAwLLh6vrmw59JifoNIv47GnxGbpCkp9SFhmkiJbyAJiEjAjAtz8HulY1Biqs\nGHkPENC3ZATt4yXI76C5ktU=\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-rcwg7@gil-sample-app.iam.gserviceaccount.com",
+ "private_key_id": "",
+ "private_key": "",
+ "client_email": "",
"client_id": "107121076566697579073",
"auth_uri": "https://accounts.google.com/o/oauth2/auth",
"token_uri": "https://accounts.google.com/o/oauth2/token",
[13/28] camel git commit: Revert "Added ASF header."
Posted by ac...@apache.org.
Revert "Added ASF header."
This reverts commit 8855e2e22290a07cc94512b95205fdcdcb0889bb.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a581c4ef
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a581c4ef
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a581c4ef
Branch: refs/heads/master
Commit: a581c4eff98663791c185893f176166b00429e9a
Parents: fc7b7db
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:58 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:58 2016 +0100
----------------------------------------------------------------------
.../services/org/apache/camel/component/firebase | 17 -----------------
1 file changed, 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/a581c4ef/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase b/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase
index 540f602..24a2a7b7 100644
--- a/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase
+++ b/components/camel-firebase/src/main/resources/META-INF/services/org/apache/camel/component/firebase
@@ -1,18 +1 @@
-#
-# 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.
-#
-
class=org.apache.camel.component.firebase.FirebaseComponent
[15/28] camel git commit: Revert "Fixed the producer which now should
be handling the async and sync flows in an improved way."
Posted by ac...@apache.org.
Revert "Fixed the producer which now should be handling the async and sync flows in an improved way."
This reverts commit d0bd0f7449f63893b0f33a3444d91a4a8e0f1acb.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/13e3e12a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/13e3e12a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/13e3e12a
Branch: refs/heads/master
Commit: 13e3e12acb1d4a0302620c0517d2f55a79cf60e0
Parents: 7530f41
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:02 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:02 2016 +0100
----------------------------------------------------------------------
.../component/firebase/FirebaseEndpoint.java | 14 ++++-----
.../component/firebase/FirebaseProducer.java | 31 ++++++++++---------
.../firebase/FirebaseProducerTest.java | 32 +++++---------------
3 files changed, 30 insertions(+), 47 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/13e3e12a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
index 41d7a61..709785e 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
@@ -52,10 +52,10 @@ public class FirebaseEndpoint extends DefaultEndpoint {
@Metadata(required = "false")
private String keyName = "firebaseKey";
- @UriParam(defaultValue = "reply", description = "If true, the save or update request (set value in Firebase terms) "
+ @UriParam(defaultValue = "async", description = "If true, the save or update request (set value in Firebase terms) "
+ "is fired and the reply will be ignored, else the routing thread will wait and the reply will be saved in the exchange message")
@Metadata(required = "false")
- private boolean reply;
+ private boolean async;
public FirebaseEndpoint(String uri, FirebaseComponent firebaseComponent, FirebaseConfig firebaseConfig) {
super(uri, firebaseComponent);
@@ -64,7 +64,7 @@ public class FirebaseEndpoint extends DefaultEndpoint {
this.setServiceAccountFile(firebaseConfig.getServiceAccountFile());
this.databaseUrl = firebaseConfig.getDatabaseUrl();
final String keyName = firebaseConfig.getKeyName();
- this.setReply(firebaseConfig.isAsync());
+ this.setAsync(firebaseConfig.isAsync());
if (keyName != null) {
this.setKeyName(keyName);
}
@@ -110,12 +110,12 @@ public class FirebaseEndpoint extends DefaultEndpoint {
this.keyName = keyName;
}
- public boolean isReply() {
- return reply;
+ public boolean isAsync() {
+ return async;
}
- public void setReply(boolean reply) {
- this.reply = reply;
+ public void setAsync(boolean async) {
+ this.async = async;
}
public FirebaseApp getFirebaseApp() {
http://git-wip-us.apache.org/repos/asf/camel/blob/13e3e12a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
index 33ba39b..ef8f8a6 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseProducer.java
@@ -22,6 +22,7 @@ import com.google.firebase.database.FirebaseDatabase;
import org.apache.camel.AsyncCallback;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
+import org.apache.camel.Processor;
import org.apache.camel.component.firebase.exception.DatabaseErrorException;
import org.apache.camel.impl.DefaultAsyncProducer;
import org.slf4j.Logger;
@@ -42,35 +43,35 @@ public class FirebaseProducer extends DefaultAsyncProducer {
rootReference = endpoint.getRootReference();
}
+ /**
+ * Processes the message exchange.
+ * Similar to {@link Processor#process}, but the caller supports having the exchange asynchronously processed.
+ * <p/>
+ * If there was a failure processing then the caused {@link Exception} would be set on the {@link Exchange}.
+ *
+ * @param exchange the message exchange
+ * @param callback the {@link AsyncCallback} will be invoked when the processing of the exchange is completed.
+ * If the exchange is completed synchronously, then the callback is also invoked synchronously.
+ * The callback should therefore be careful of starting recursive loop.
+ * @return (doneSync) <tt>true</tt> to continue execute synchronously, <tt>false</tt> to continue being executed asynchronously
+ */
@Override
public boolean process(Exchange exchange, AsyncCallback callback) {
final Message in = exchange.getIn();
- final Message out = exchange.getOut();
String firebaseKey = (String) in.getHeader(endpoint.getKeyName());
Object value = in.getBody();
DatabaseReference ref = FirebaseDatabase
.getInstance(endpoint.getFirebaseApp())
.getReference(rootReference).child(firebaseKey);
- final boolean reply = endpoint.isReply();
- out.setHeaders(in.getHeaders());
- if (reply) { // Wait for reply
- processReply(exchange, callback, value, ref);
- } else { // Fire and forget
- ref.setValue(value);
- out.setBody(in.getBody());
- callback.done(true);
- }
- return !reply;
- }
-
- private void processReply(Exchange exchange, AsyncCallback callback, Object value, DatabaseReference ref) {
ref.setValue(value, (DatabaseError databaseError, DatabaseReference databaseReference) -> {
if (databaseError != null) {
exchange.setException(new DatabaseErrorException(databaseError));
+ exchange.getOut().setFault(true);
} else {
exchange.getOut().setBody(databaseReference);
}
- callback.done(false);
+ callback.done(endpoint.isAsync());
});
+ return endpoint.isAsync();
}
}
http://git-wip-us.apache.org/repos/asf/camel/blob/13e3e12a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
index 973b2ee..f0f2cc3 100644
--- a/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
+++ b/components/camel-firebase/src/test/java/org/apache/camel/component/firebase/FirebaseProducerTest.java
@@ -22,9 +22,6 @@ import java.nio.file.Paths;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
-import static java.util.stream.IntStream.range;
-import static junit.framework.TestCase.fail;
-
import com.google.firebase.database.DatabaseReference;
import org.apache.camel.CamelContext;
import org.apache.camel.Message;
@@ -55,28 +52,16 @@ public class FirebaseProducerTest {
}
@Test
- public void whenFirebaseSetShouldReceiveMessageAsDBReference() throws Exception {
- startRoute(true, DatabaseReference.class);
+ public void whenFirebaseSetShouldReceiveMessagesSync() throws Exception {
+ startRoute(false, DatabaseReference.class);
}
@Test
- public void whenFirebaseSetShouldReceiveMessageAsDbString() throws Exception {
- startRoute(false, String.class);
+ public void whenFirebaseSetShouldReceiveMessagesAsync() throws Exception {
+ startRoute(true, String.class);
}
- @Test
- public void whenMultipleFirebaseSetShouldReceiveExpectedMessages() {
- range(0, 10).forEach(i -> {
- try {
- startRoute(true, DatabaseReference.class);
- startRoute(false, String.class);
- } catch (Exception e) {
- fail("Multiple test fails: " + e);
- }
- });
- }
-
- private void startRoute(final boolean reply, final Class<?> expectedBodyClass) throws Exception {
+ private void startRoute(final boolean async, final Class<?> expectedBodyClass) throws Exception {
sampleInputProvider.copySampleFile();
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
@@ -93,14 +78,11 @@ public class FirebaseProducerTest {
out.setHeader("firebaseKey", keyValue[0]);
out.setBody(keyValue[1].trim());
})
- .to(String.format("firebase://%s?rootReference=%s&serviceAccountFile=%s&reply=%b",
- ConfigurationProvider.createDatabaseUrl(), rootReference, serviceAccountFile, reply))
+ .to(String.format("firebase://%s?rootReference=%s&serviceAccountFile=%s&async=%b",
+ ConfigurationProvider.createDatabaseUrl(), rootReference, serviceAccountFile, async))
.to("log:whenFirebaseSet?level=WARN")
.process(exchange1 -> {
assertThat(exchange1.getIn().getBody().getClass()).isEqualTo(expectedBodyClass);
- if (reply) {
- assertThat(exchange1.getIn().getHeader("firebaseKey")).isNotNull();
- }
try {
reentrantLock.lock();
wake.signal();
[02/28] camel git commit: Revert "Camel-Firebase: Added component to
parent"
Posted by ac...@apache.org.
Revert "Camel-Firebase: Added component to parent"
This reverts commit a4fc5a0455f78a62776eab2189c8c185183fd047.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/09d212e0
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/09d212e0
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/09d212e0
Branch: refs/heads/master
Commit: 09d212e08cd0fd58bded7fa8d20d1b38795aa65b
Parents: 200226a
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:29 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:29 2016 +0100
----------------------------------------------------------------------
parent/pom.xml | 5 -----
1 file changed, 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/09d212e0/parent/pom.xml
----------------------------------------------------------------------
diff --git a/parent/pom.xml b/parent/pom.xml
index 7064016..fc43c93 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -1017,11 +1017,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-firebase</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-flatpack</artifactId>
<version>${project.version}</version>
</dependency>
[06/28] camel git commit: Revert "Improved the endpoint and the
general documentation."
Posted by ac...@apache.org.
Revert "Improved the endpoint and the general documentation."
This reverts commit 18f5be656d05b0ab95e2fb66f3f3aade6d6d5fff.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d6dbf5ce
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d6dbf5ce
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d6dbf5ce
Branch: refs/heads/master
Commit: d6dbf5ce25bec6a3671f14696cfbc90a6ed30586
Parents: 1a16fac
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:41 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:41 2016 +0100
----------------------------------------------------------------------
components/camel-firebase/src/main/docs/firebase-component.adoc | 4 ++--
.../org/apache/camel/component/firebase/FirebaseEndpoint.java | 5 +----
2 files changed, 3 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/d6dbf5ce/components/camel-firebase/src/main/docs/firebase-component.adoc
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/docs/firebase-component.adoc b/components/camel-firebase/src/main/docs/firebase-component.adoc
index 29c912b..4d6837a 100644
--- a/components/camel-firebase/src/main/docs/firebase-component.adoc
+++ b/components/camel-firebase/src/main/docs/firebase-component.adoc
@@ -4,8 +4,8 @@ Firebase Component
*Available as of Camel 2.19*
-The *Firebase*�component enables you to save, modify data in Google Firebase database.
-Furthermore it allows you to consume and process all child events mapped to a specific Firebase reference.
+The *firebase*�component enables you to save, modify data in Google Firebase database
+and consume to all child of a specific reference.
This component supports producer and event based consumer endpoints.
http://git-wip-us.apache.org/repos/asf/camel/blob/d6dbf5ce/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
index 38e254d..41d7a61 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseEndpoint.java
@@ -27,10 +27,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
/**
- * The Google Firebase�component enables you to save and modify data in a Google Firebase database
- * via the {@link FirebaseProducer} class.
- * Furthermore it allows you to consume and process all child events mapped to a specific Firebase reference
- * via the {@link FirebaseConsumer} class.
+ * Represents a Firebase endpoint.
*/
@UriEndpoint(scheme = "firebase", title = "Firebase", syntax = "firebase:databaseUrl", consumerClass = FirebaseConsumer.class, label = "cloud,messaging")
public class FirebaseEndpoint extends DefaultEndpoint {
[04/28] camel git commit: Revert "Camel-Firebase: Added
camel-firebase-starter to starters"
Posted by ac...@apache.org.
Revert "Camel-Firebase: Added camel-firebase-starter to starters"
This reverts commit 7afa2eb1b8963d2e9ded3f745965942feac90b50.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ae1fdbc7
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ae1fdbc7
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ae1fdbc7
Branch: refs/heads/master
Commit: ae1fdbc72658dfe703cb2d04a908248b384822d3
Parents: 96b44a3
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:35 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:35 2016 +0100
----------------------------------------------------------------------
.../camel-firebase-starter/pom.xml | 59 ------
.../FirebaseComponentAutoConfiguration.java | 43 ----
.../src/main/resources/META-INF/LICENSE.txt | 203 -------------------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../main/resources/META-INF/spring.factories | 19 --
.../src/main/resources/META-INF/spring.provides | 18 --
components-starter/pom.xml | 1 -
parent/pom.xml | 1 -
8 files changed, 355 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/ae1fdbc7/components-starter/camel-firebase-starter/pom.xml
----------------------------------------------------------------------
diff --git a/components-starter/camel-firebase-starter/pom.xml b/components-starter/camel-firebase-starter/pom.xml
deleted file mode 100644
index bbaa91d..0000000
--- a/components-starter/camel-firebase-starter/pom.xml
+++ /dev/null
@@ -1,59 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- 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.
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>components-starter</artifactId>
- <version>2.19.0-SNAPSHOT</version>
- </parent>
- <artifactId>camel-firebase-starter</artifactId>
- <packaging>jar</packaging>
- <name>Spring-Boot Starter :: Camel :: Firebase</name>
- <description>Spring-Boot Starter for Camel Components</description>
- <dependencies>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter</artifactId>
- <version>${spring-boot-version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-firebase</artifactId>
- <version>${project.version}</version>
- <!--START OF GENERATED CODE-->
- <exclusions>
- <exclusion>
- <groupId>commons-logging</groupId>
- <artifactId>commons-logging</artifactId>
- </exclusion>
- </exclusions>
- <!--END OF GENERATED CODE-->
- </dependency>
- <!--START OF GENERATED CODE-->
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-core-starter</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-spring-boot-starter</artifactId>
- </dependency>
- <!--END OF GENERATED CODE-->
- </dependencies>
-</project>
http://git-wip-us.apache.org/repos/asf/camel/blob/ae1fdbc7/components-starter/camel-firebase-starter/src/main/java/org/apache/camel/component/firebase/springboot/FirebaseComponentAutoConfiguration.java
----------------------------------------------------------------------
diff --git a/components-starter/camel-firebase-starter/src/main/java/org/apache/camel/component/firebase/springboot/FirebaseComponentAutoConfiguration.java b/components-starter/camel-firebase-starter/src/main/java/org/apache/camel/component/firebase/springboot/FirebaseComponentAutoConfiguration.java
deleted file mode 100644
index 406a266..0000000
--- a/components-starter/camel-firebase-starter/src/main/java/org/apache/camel/component/firebase/springboot/FirebaseComponentAutoConfiguration.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/**
- * 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.firebase.springboot;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.component.firebase.FirebaseComponent;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-/**
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Configuration
-@ConditionalOnBean(type = "org.apache.camel.springboot.CamelAutoConfiguration")
-public class FirebaseComponentAutoConfiguration {
-
- @Bean(name = "firebase-component")
- @ConditionalOnClass(CamelContext.class)
- @ConditionalOnMissingBean(FirebaseComponent.class)
- public FirebaseComponent configureFirebaseComponent(
- CamelContext camelContext) throws Exception {
- FirebaseComponent component = new FirebaseComponent();
- component.setCamelContext(camelContext);
- return component;
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/ae1fdbc7/components-starter/camel-firebase-starter/src/main/resources/META-INF/LICENSE.txt
----------------------------------------------------------------------
diff --git a/components-starter/camel-firebase-starter/src/main/resources/META-INF/LICENSE.txt b/components-starter/camel-firebase-starter/src/main/resources/META-INF/LICENSE.txt
deleted file mode 100644
index 6b0b127..0000000
--- a/components-starter/camel-firebase-starter/src/main/resources/META-INF/LICENSE.txt
+++ /dev/null
@@ -1,203 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
- http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that is based on (or derived from) the Work and for which the
- editorial revisions, annotations, elaborations, or other modifications
- represent, as a whole, an original work of authorship. For the purposes
- of this License, Derivative Works shall not include works that remain
- separable from, or merely link (or bind by name) to the interfaces of,
- the Work and Derivative Works thereof.
-
- "Contribution" shall mean any work of authorship, including
- the original version of the Work and any modifications or additions
- to that Work or Derivative Works thereof, that is intentionally
- submitted to Licensor for inclusion in the Work by the copyright owner
- or by an individual or Legal Entity authorized to submit on behalf of
- the copyright owner. For the purposes of this definition, "submitted"
- means any form of electronic, verbal, or written communication sent
- to the Licensor or its representatives, including but not limited to
- communication on electronic mailing lists, source code control systems,
- and issue tracking systems that are managed by, or on behalf of, the
- Licensor for the purpose of discussing and improving the Work, but
- excluding communication that is conspicuously marked or otherwise
- designated in writing by the copyright owner as "Not a Contribution."
-
- "Contributor" shall mean Licensor and any individual or Legal Entity
- on behalf of whom a Contribution has been received by Licensor and
- subsequently incorporated within the Work.
-
- 2. Grant of Copyright License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- copyright license to reproduce, prepare Derivative Works of,
- publicly display, publicly perform, sublicense, and distribute the
- Work and such Derivative Works in Source or Object form.
-
- 3. Grant of Patent License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- (except as stated in this section) patent license to make, have made,
- use, offer to sell, sell, import, and otherwise transfer the Work,
- where such license applies only to those patent claims licensable
- by such Contributor that are necessarily infringed by their
- Contribution(s) alone or by combination of their Contribution(s)
- with the Work to which such Contribution(s) was submitted. If You
- institute patent litigation against any entity (including a
- cross-claim or counterclaim in a lawsuit) alleging that the Work
- or a Contribution incorporated within the Work constitutes direct
- or contributory patent infringement, then any patent licenses
- granted to You under this License for that Work shall terminate
- as of the date such litigation is filed.
-
- 4. Redistribution. You may reproduce and distribute copies of the
- Work or Derivative Works thereof in any medium, with or without
- modifications, and in Source or Object form, provided that You
- meet the following conditions:
-
- (a) You must give any other recipients of the Work or
- Derivative Works a copy of this License; and
-
- (b) You must cause any modified files to carry prominent notices
- stating that You changed the files; and
-
- (c) You must retain, in the Source form of any Derivative Works
- that You distribute, all copyright, patent, trademark, and
- attribution notices from the Source form of the Work,
- excluding those notices that do not pertain to any part of
- the Derivative Works; and
-
- (d) If the Work includes a "NOTICE" text file as part of its
- distribution, then any Derivative Works that You distribute must
- include a readable copy of the attribution notices contained
- within such NOTICE file, excluding those notices that do not
- pertain to any part of the Derivative Works, in at least one
- of the following places: within a NOTICE text file distributed
- as part of the Derivative Works; within the Source form or
- documentation, if provided along with the Derivative Works; or,
- within a display generated by the Derivative Works, if and
- wherever such third-party notices normally appear. The contents
- of the NOTICE file are for informational purposes only and
- do not modify the License. You may add Your own attribution
- notices within Derivative Works that You distribute, alongside
- or as an addendum to the NOTICE text from the Work, provided
- that such additional attribution notices cannot be construed
- as modifying the License.
-
- You may add Your own copyright statement to Your modifications and
- may provide additional or different license terms and conditions
- for use, reproduction, or distribution of Your modifications, or
- for any such Derivative Works as a whole, provided Your use,
- reproduction, and distribution of the Work otherwise complies with
- the conditions stated in this License.
-
- 5. Submission of Contributions. Unless You explicitly state otherwise,
- any Contribution intentionally submitted for inclusion in the Work
- by You to the Licensor shall be under the terms and conditions of
- this License, without any additional terms or conditions.
- Notwithstanding the above, nothing herein shall supersede or modify
- the terms of any separate license agreement you may have executed
- with Licensor regarding such Contributions.
-
- 6. Trademarks. This License does not grant permission to use the trade
- names, trademarks, service marks, or product names of the Licensor,
- except as required for reasonable and customary use in describing the
- origin of the Work and reproducing the content of the NOTICE file.
-
- 7. Disclaimer of Warranty. Unless required by applicable law or
- agreed to in writing, Licensor provides the Work (and each
- Contributor provides its Contributions) on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- implied, including, without limitation, any warranties or conditions
- of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
- PARTICULAR PURPOSE. You are solely responsible for determining the
- appropriateness of using or redistributing the Work and assume any
- risks associated with Your exercise of permissions under this License.
-
- 8. Limitation of Liability. In no event and under no legal theory,
- whether in tort (including negligence), contract, or otherwise,
- unless required by applicable law (such as deliberate and grossly
- negligent acts) or agreed to in writing, shall any Contributor be
- liable to You for damages, including any direct, indirect, special,
- incidental, or consequential damages of any character arising as a
- result of this License or out of the use or inability to use the
- Work (including but not limited to damages for loss of goodwill,
- work stoppage, computer failure or malfunction, or any and all
- other commercial damages or losses), even if such Contributor
- has been advised of the possibility of such damages.
-
- 9. Accepting Warranty or Additional Liability. While redistributing
- the Work or Derivative Works thereof, You may choose to offer,
- and charge a fee for, acceptance of support, warranty, indemnity,
- or other liability obligations and/or rights consistent with this
- License. However, in accepting such obligations, You may act only
- on Your own behalf and on Your sole responsibility, not on behalf
- of any other Contributor, and only if You agree to indemnify,
- defend, and hold each Contributor harmless for any liability
- incurred by, or claims asserted against, such Contributor by reason
- of your accepting any such warranty or additional liability.
-
- END OF TERMS AND CONDITIONS
-
- APPENDIX: How to apply the Apache License to your work.
-
- To apply the Apache License to your work, attach the following
- boilerplate notice, with the fields enclosed by brackets "[]"
- replaced with your own identifying information. (Don't include
- the brackets!) The text should be enclosed in the appropriate
- comment syntax for the file format. We also recommend that a
- file or class name and description of purpose be included on the
- same "printed page" as the copyright notice for easier
- identification within third-party archives.
-
- Copyright [yyyy] [name of copyright owner]
-
- Licensed 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.
-
http://git-wip-us.apache.org/repos/asf/camel/blob/ae1fdbc7/components-starter/camel-firebase-starter/src/main/resources/META-INF/NOTICE.txt
----------------------------------------------------------------------
diff --git a/components-starter/camel-firebase-starter/src/main/resources/META-INF/NOTICE.txt b/components-starter/camel-firebase-starter/src/main/resources/META-INF/NOTICE.txt
deleted file mode 100644
index 2e215bf..0000000
--- a/components-starter/camel-firebase-starter/src/main/resources/META-INF/NOTICE.txt
+++ /dev/null
@@ -1,11 +0,0 @@
- =========================================================================
- == NOTICE file corresponding to the section 4 d of ==
- == the Apache License, Version 2.0, ==
- == in this case for the Apache Camel distribution. ==
- =========================================================================
-
- This product includes software developed by
- The Apache Software Foundation (http://www.apache.org/).
-
- Please read the different LICENSE files present in the licenses directory of
- this distribution.
http://git-wip-us.apache.org/repos/asf/camel/blob/ae1fdbc7/components-starter/camel-firebase-starter/src/main/resources/META-INF/spring.factories
----------------------------------------------------------------------
diff --git a/components-starter/camel-firebase-starter/src/main/resources/META-INF/spring.factories b/components-starter/camel-firebase-starter/src/main/resources/META-INF/spring.factories
deleted file mode 100644
index 26166fc..0000000
--- a/components-starter/camel-firebase-starter/src/main/resources/META-INF/spring.factories
+++ /dev/null
@@ -1,19 +0,0 @@
-#
-# 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.
-#
-
-org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
-org.apache.camel.component.firebase.springboot.FirebaseComponentAutoConfiguration
http://git-wip-us.apache.org/repos/asf/camel/blob/ae1fdbc7/components-starter/camel-firebase-starter/src/main/resources/META-INF/spring.provides
----------------------------------------------------------------------
diff --git a/components-starter/camel-firebase-starter/src/main/resources/META-INF/spring.provides b/components-starter/camel-firebase-starter/src/main/resources/META-INF/spring.provides
deleted file mode 100644
index 5ac28a4..0000000
--- a/components-starter/camel-firebase-starter/src/main/resources/META-INF/spring.provides
+++ /dev/null
@@ -1,18 +0,0 @@
-#
-# 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.
-#
-
-provides: camel-firebase
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/ae1fdbc7/components-starter/pom.xml
----------------------------------------------------------------------
diff --git a/components-starter/pom.xml b/components-starter/pom.xml
index 26a2f95..5dc6005 100644
--- a/components-starter/pom.xml
+++ b/components-starter/pom.xml
@@ -125,7 +125,6 @@
<module>camel-etcd-starter</module>
<module>camel-exec-starter</module>
<module>camel-facebook-starter</module>
- <module>camel-firebase-starter</module>
<module>camel-flatpack-starter</module>
<module>camel-flink-starter</module>
<module>camel-fop-starter</module>
http://git-wip-us.apache.org/repos/asf/camel/blob/ae1fdbc7/parent/pom.xml
----------------------------------------------------------------------
diff --git a/parent/pom.xml b/parent/pom.xml
index fc43c93..aa4103d 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -57,7 +57,6 @@
<arquillian-weld-embedded-version>2.0.0.Beta3</arquillian-weld-embedded-version>
<asm-bundle-version>3.3.1_1</asm-bundle-version>
<asm-version>3.3.1</asm-version>
- <assertj-core.version>3.5.2</assertj-core.version>
<aspectj-version>1.8.9</aspectj-version>
<asterisk-java-version>1.0.0-final</asterisk-java-version>
<asterisk-java-bundle-version>1.0.0-final_1</asterisk-java-bundle-version>
[20/28] camel git commit: Revert "Using the ootb methods for
parameter retrieval."
Posted by ac...@apache.org.
Revert "Using the ootb methods for parameter retrieval."
This reverts commit 371804259a85d67ef0554b109ecd6b319a6149c9.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4d69eca1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4d69eca1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4d69eca1
Branch: refs/heads/master
Commit: 4d69eca166878a3299f4b8d7719d5c9caf102dc8
Parents: c1c7a70
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:14 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:14 2016 +0100
----------------------------------------------------------------------
.../org/apache/camel/component/firebase/FirebaseComponent.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/4d69eca1/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
index 0f62e16..8b80a2a 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
@@ -1,4 +1,4 @@
-/*
+/**
* 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.
@@ -39,8 +39,8 @@ public class FirebaseComponent extends UriEndpointComponent {
FirebaseConfig firebaseConfig = new FirebaseConfig.Builder(
String.format("https://%s", remaining),
- getAndRemoveParameter(parameters, "rootReference", String.class),
- getAndRemoveParameter(parameters, "serviceAccountFile", String.class))
+ (String) parameters.get("rootReference"),
+ (String) parameters.get("serviceAccountFile"))
.build();
firebaseConfig.init();
[17/28] camel git commit: Revert "Moved assertj version to parent
pom.xml"
Posted by ac...@apache.org.
Revert "Moved assertj version to parent pom.xml"
This reverts commit 1305ce4c7b2601230c428655ade3901c0ef21cf5.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/bf436637
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/bf436637
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/bf436637
Branch: refs/heads/master
Commit: bf4366374fd716d9633e98c11f1238cc4ecf8fdb
Parents: 6b42082
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:07 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:07 2016 +0100
----------------------------------------------------------------------
components/camel-firebase/pom.xml | 2 +-
components/pom.xml | 1 -
2 files changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/bf436637/components/camel-firebase/pom.xml
----------------------------------------------------------------------
diff --git a/components/camel-firebase/pom.xml b/components/camel-firebase/pom.xml
index c5944dd..9521fb9 100644
--- a/components/camel-firebase/pom.xml
+++ b/components/camel-firebase/pom.xml
@@ -57,7 +57,7 @@
<dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
- <version>${assertj-core.version}</version>
+ <version>3.5.2</version>
<scope>test</scope>
</dependency>
</dependencies>
http://git-wip-us.apache.org/repos/asf/camel/blob/bf436637/components/pom.xml
----------------------------------------------------------------------
diff --git a/components/pom.xml b/components/pom.xml
index bd9e707..8f7d0e5 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -276,7 +276,6 @@
<module>camel-zipfile</module>
<module>camel-zipkin</module>
<module>camel-zookeeper</module>
- <module>camel-firebase</module>
</modules>
[12/28] camel git commit: Revert "Logging now to a file in the target
folder."
Posted by ac...@apache.org.
Revert "Logging now to a file in the target folder."
This reverts commit c2f3e4d418d8b5c976d2752d309fbce701bc903d.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fc7b7db5
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fc7b7db5
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fc7b7db5
Branch: refs/heads/master
Commit: fc7b7db5fa3d3dd3b030ecedef9103412078f099
Parents: 827fd43
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:49:56 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:49:56 2016 +0100
----------------------------------------------------------------------
.../src/test/resources/log4j2.properties | 31 ++------------------
1 file changed, 3 insertions(+), 28 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/fc7b7db5/components/camel-firebase/src/test/resources/log4j2.properties
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/log4j2.properties b/components/camel-firebase/src/test/resources/log4j2.properties
index 08ddb6a..328db35 100644
--- a/components/camel-firebase/src/test/resources/log4j2.properties
+++ b/components/camel-firebase/src/test/resources/log4j2.properties
@@ -1,32 +1,7 @@
-## ---------------------------------------------------------------------------
-## 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.
-## ---------------------------------------------------------------------------
-appender.out.type = File
+appender.out.type = Console
appender.out.name = out
-appender.out.fileName = target/camel-firebase-test.log
appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-appender.stdout.type = Console
-appender.stdout.name = stdout
-appender.stdout.layout.type = PatternLayout
-appender.stdout.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-logger.camel.name = org.apache.camel
-logger.camel.level = DEBUG
-logger.firebase.name = org.apache.camel.firebase
-logger.firebase.level = DEBUG
+appender.out.layout.pattern = [%30.30t] %-30.30c{1} %-5p %m%n
rootLogger.level = INFO
-rootLogger.appenderRef.out.ref = out
\ No newline at end of file
+rootLogger.appenderRef.out.ref = out
[27/28] camel git commit: Revert "Added first version of the Camel
Firebase component."
Posted by ac...@apache.org.
Revert "Added first version of the Camel Firebase component."
This reverts commit 93911bcd1388d028d3fc1be06dc506eb26025cec.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/520160fc
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/520160fc
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/520160fc
Branch: refs/heads/master
Commit: 520160fc354de0b3cdc7f67336db6b9d9244f341
Parents: e853931
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:37 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:37 2016 +0100
----------------------------------------------------------------------
.../gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/520160fc/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json b/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
index 69feae7..7a9f352 100644
--- a/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
+++ b/components/camel-firebase/src/test/resources/gil-sample-app-firebase-adminsdk-rcwg7-fea519a672.json
@@ -1,9 +1,9 @@
{
"type": "service_account",
"project_id": "gil-sample-app",
- "private_key_id": "",
- "private_key": "",
- "client_email": "",
+ "private_key_id": "fea519a672d21f7667afb1badbeb858342ae32ac",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDX88p2HcAn2z0t\n7uAk0jB0RUyi4f+SWd3ofM6Ju59XLyttnbXKEYNBnjIE3YOJ49Xd92vFXGsYU+DU\nb7vFf/rXtfiZglE6zHF8p+53Jy/AJKWHLWKa+nZa4vUQASmBGJy5SF37YJhaE/Mu\nUqNESdZowdjro4bE3D/VYZsK/9UmHEO8PmlKL9Igl4WVq5I1toJk1eae/2nBmE3+\n3/uGrTf6ydJ8xx/tPMwWGLRNYxb4PQliTTCaLc5dR/p9B8YMwMtuxWU9IereIKp8\n51ZgYW6e/6IHbfb22cp2NwKHxwvnZu5HZ1+IIZ+3n9S2OJYZGPBIB7xJzSd6xXAf\nXAQqYzMDAgMBAAECggEAYfbEJ6UDYJFCRa4RnGKFfJlbVKC1MYz279p+T1j/xasu\nRkG/D/W113SOOErMuybSBCmTiCqOorCaU4SEZ+nQvz5bkjfd5ZCNAwGjWgY60S1O\nse3Sx39LZZuDlEkSrO+fWSYNDFYbhvF55c+zJO1iCI+3ed3q6y8G/iOTFABOj0R5\nZ7pPJqzXIg3sKRaMOJ+l2F8/nIZ8AUyesByJgP4UuyYTb9LaqRqIz/URYh2xVohW\n3MkXmCDkY5tyzJ7rwJloHoOo4Hsvefzgv3dDJYu4FJ7BUHFyNa6yZDGdte49WQsS\nDNEwEDvBPsE00olbsjAkSpdC0u57836Vn81Xz84y4QKBgQD63EWzFrVx0w+8PSy8\nPqZgQWEwHb09r2c9TjaxqohtapqFZZ5szEiOOad8r369RQ6bVIMzYzYRBUGDkZj7\nmDBB1lglgYC+NEHZAaObXPzVngAN3fRW7a+IRQLOlYqd8Er0v0jw37R6PjAXFz/5\nFtnX0eMnA0MfNqN9mhKyvgX7mQ
KBgQDcYG4sUOSIO3BG7z9ufL0aiyfERFg6gTJ1\n05xXVNHJBRh+nu6bXPp+a76myiR0QPhXhKuok7PC4opcmreeN4401MGSStgp4Xng\nM/vpMd3knw0zn9DY5FrFdxtIs8YFBcu2XkJzz+rM1IAw563wLRQAuUbb+AOtspZ1\noDZ2ssQk+wKBgE+Oa8xP91sRxHu+KuHIPJtqIJhR1iIp7mPS2iWeH4YTuM11XLjE\nUH5KaoNwZJFBxVAdjT5OyGa9c/l1wz6HFUbL40iBuYKYsAlSK8CpzMUyRnIfYc3v\nsytUN3+sjTlpa1wTDd7WEzZxYm7wQKmORafcOF22+yJ7AX5jzmpBOUSBAoGBAIkY\nLDHBeQoPAAAA4hMX4oRawThl1AVBTmTiacYibAeD9gL/WCyqoOJ4oLgd1KPFrziy\nvh83E4NPbwfA8C2rHfpbyLf7e5JCRJFnhXVCommRUKMm7sOe+6EQQZbuz2dcfahL\n50cot0cJg13pItnhESqKGDzLg25RRSyTqI4bE851AoGAHAixBamIjbFDuSxx9wQ6\n8qy1eB0h66BvZ+YWrXaI6v9zBBSRrdnda35oFVAOFV4LZ6NNsg88ODX/kt9vU5CB\nEmQYAwLLh6vrmw59JifoNIv47GnxGbpCkp9SFhmkiJbyAJiEjAjAtz8HulY1Biqs\nGHkPENC3ZATt4yXI76C5ktU=\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-rcwg7@gil-sample-app.iam.gserviceaccount.com",
"client_id": "107121076566697579073",
"auth_uri": "https://accounts.google.com/o/oauth2/auth",
"token_uri": "https://accounts.google.com/o/oauth2/token",
[21/28] camel git commit: Revert "Removed FirebaseException."
Posted by ac...@apache.org.
Revert "Removed FirebaseException."
This reverts commit 522f3e13707a8a90810aa9d1165420604fc74358.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cd88ad1e
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cd88ad1e
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cd88ad1e
Branch: refs/heads/master
Commit: cd88ad1e75792ae31066fb4e52d660217958b4a6
Parents: 4d69eca
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:16 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:16 2016 +0100
----------------------------------------------------------------------
.../component/firebase/FirebaseConsumer.java | 4 +-
.../firebase/exception/FirebaseException.java | 42 ++++++++++++++++++++
2 files changed, 44 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/cd88ad1e/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
index e85b307..bbcb2b6 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
@@ -22,9 +22,9 @@ import com.google.firebase.database.DatabaseError;
import com.google.firebase.database.FirebaseDatabase;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
-import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.firebase.data.FirebaseMessage;
import org.apache.camel.component.firebase.data.Operation;
+import org.apache.camel.component.firebase.exception.FirebaseException;
import org.apache.camel.impl.DefaultConsumer;
/**
@@ -87,7 +87,7 @@ public class FirebaseConsumer extends DefaultConsumer {
// send message to next processor in the route
getProcessor().process(exchange);
} catch (Exception e) {
- throw new RuntimeCamelException("Message forwarding failed", e);
+ throw new FirebaseException("Message forwarding failed", e);
} finally {
// log exception if an exception occurred and was not handled
if (exchange.getException() != null) {
http://git-wip-us.apache.org/repos/asf/camel/blob/cd88ad1e/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
new file mode 100644
index 0000000..a39b871
--- /dev/null
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/exception/FirebaseException.java
@@ -0,0 +1,42 @@
+/**
+ * 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.firebase.exception;
+
+/**
+ * Used to mark an exception occurred in the Firebase Camel processor.
+ */
+public class FirebaseException extends RuntimeException {
+
+ /**
+ * Constructs a new runtime exception with the specified detail message and
+ * cause. <p>Note that the detail message associated with
+ * {@code cause} is <i>not</i> automatically incorporated in
+ * this runtime exception's detail message.
+ *
+ * @param message the detail message (which is saved for later retrieval
+ * by the {@link #getMessage()} method).
+ * @param cause the cause (which is saved for later retrieval by the
+ * {@link #getCause()} method). (A <tt>null</tt> value is
+ * permitted, and indicates that the cause is nonexistent or
+ * unknown.)
+ * @since 1.4
+ */
+ public FirebaseException(String message, Throwable cause) {
+ super(message, cause);
+ }
+
+}
[16/28] camel git commit: Revert "Moved the child event listener to a
separate class and also fixed the comment styles."
Posted by ac...@apache.org.
Revert "Moved the child event listener to a separate class and also fixed the comment styles."
This reverts commit 875740078b343a1aea66080657442ad9e3ae9e79.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/6b42082e
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6b42082e
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6b42082e
Branch: refs/heads/master
Commit: 6b42082eef9b86303d306ee33b72f0ad84ee36c6
Parents: 13e3e12
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Nov 25 12:50:05 2016 +0100
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Nov 25 12:50:05 2016 +0100
----------------------------------------------------------------------
.../component/firebase/FirebaseComponent.java | 2 +-
.../component/firebase/FirebaseConsumer.java | 64 ++++++++++----------
2 files changed, 32 insertions(+), 34 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/6b42082e/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
index f06e06d..0f62e16 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseComponent.java
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
http://git-wip-us.apache.org/repos/asf/camel/blob/6b42082e/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
index c8859eb..e85b307 100644
--- a/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
+++ b/components/camel-firebase/src/main/java/org/apache/camel/component/firebase/FirebaseConsumer.java
@@ -47,7 +47,36 @@ public class FirebaseConsumer extends DefaultConsumer {
FirebaseDatabase
.getInstance(endpoint.getFirebaseApp())
.getReference(firebaseConfig.getRootReference())
- .addChildEventListener(new FirebaseConsumerEventListener());
+ .addChildEventListener(new ChildEventListener() {
+ @Override
+ public void onChildAdded(DataSnapshot dataSnapshot, String s) {
+ forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_ADD, dataSnapshot)
+ .setPreviousChildName(s).build());
+ }
+
+ @Override
+ public void onChildChanged(DataSnapshot dataSnapshot, String s) {
+ forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_CHANGED, dataSnapshot)
+ .setPreviousChildName(s).build());
+ }
+
+ @Override
+ public void onChildRemoved(DataSnapshot dataSnapshot) {
+ forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_REMOVED, dataSnapshot).build());
+ }
+
+ @Override
+ public void onChildMoved(DataSnapshot dataSnapshot, String s) {
+ forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_MOVED, dataSnapshot)
+ .setPreviousChildName(s).build());
+ }
+
+ @Override
+ public void onCancelled(DatabaseError databaseError) {
+ forwardMessage(new FirebaseMessage.Builder(Operation.CANCELLED).setDatabaseError(databaseError)
+ .build());
+ }
+ });
}
private void forwardMessage(FirebaseMessage o) {
@@ -58,7 +87,7 @@ public class FirebaseConsumer extends DefaultConsumer {
// send message to next processor in the route
getProcessor().process(exchange);
} catch (Exception e) {
- exchange.setException(new RuntimeCamelException("Message forwarding failed", e));
+ throw new RuntimeCamelException("Message forwarding failed", e);
} finally {
// log exception if an exception occurred and was not handled
if (exchange.getException() != null) {
@@ -66,35 +95,4 @@ public class FirebaseConsumer extends DefaultConsumer {
}
}
}
-
- private class FirebaseConsumerEventListener implements ChildEventListener {
- @Override
- public void onChildAdded(DataSnapshot dataSnapshot, String s) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_ADD, dataSnapshot)
- .setPreviousChildName(s).build());
- }
-
- @Override
- public void onChildChanged(DataSnapshot dataSnapshot, String s) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_CHANGED, dataSnapshot)
- .setPreviousChildName(s).build());
- }
-
- @Override
- public void onChildRemoved(DataSnapshot dataSnapshot) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_REMOVED, dataSnapshot).build());
- }
-
- @Override
- public void onChildMoved(DataSnapshot dataSnapshot, String s) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CHILD_MOVED, dataSnapshot)
- .setPreviousChildName(s).build());
- }
-
- @Override
- public void onCancelled(DatabaseError databaseError) {
- forwardMessage(new FirebaseMessage.Builder(Operation.CANCELLED).setDatabaseError(databaseError)
- .build());
- }
- }
}