camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [28/28] camel git commit: Camel-Firebase: removed component
Date Fri, 25 Nov 2016 12:17:51 GMT
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 <ancosen@gmail.com>
Authored: Fri Nov 25 12:51:48 2016 +0100
Committer: Andrea Cosentino <ancosen@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


Mime
View raw message