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 <anco...@gmail.com> Authored: Fri Nov 25 12:51:48 2016 +0100 Committer: Andrea Cosentino <anco...@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-rc...@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
