camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lburgazz...@apache.org
Subject camel git commit: Fix spelling, component pom
Date Fri, 22 Jul 2016 08:02:04 GMT
Repository: camel
Updated Branches:
  refs/heads/master 1c148887c -> 2bbc1368b


Fix spelling, component pom


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

Branch: refs/heads/master
Commit: 2bbc1368b233f630f6acbf6d6c8d52ec5f1d1772
Parents: 1c14888
Author: lburgazzoli <lburgazzoli@gmail.com>
Authored: Fri Jul 22 10:01:21 2016 +0200
Committer: lburgazzoli <lburgazzoli@gmail.com>
Committed: Fri Jul 22 10:01:21 2016 +0200

----------------------------------------------------------------------
 .../engine/ChronicleEngineComponent.java        |  8 +-
 .../engine/ChronicleEngineConsumer.java         |  4 +-
 .../engine/ChronicleEngineEndpoint.java         | 96 ++++++++++++++++++++
 .../engine/ChronicleEngineEnpoint.java          | 96 --------------------
 .../engine/ChronicleEngineProducer.java         |  4 +-
 components/pom.xml                              |  1 +
 6 files changed, 105 insertions(+), 104 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/2bbc1368/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineComponent.java
b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineComponent.java
index bbc6975..06d7d7d 100644
--- a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineComponent.java
+++ b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineComponent.java
@@ -24,16 +24,16 @@ import org.apache.camel.impl.UriEndpointComponent;
 import org.apache.camel.util.ObjectHelper;
 
 /**
- * Represents the component that manages {@link ChronicleEngineEnpoint}.
+ * Represents the component that manages {@link ChronicleEngineEndpoint}.
  */
 public class ChronicleEngineComponent extends UriEndpointComponent {
     
     public ChronicleEngineComponent() {
-        super(ChronicleEngineEnpoint.class);
+        super(ChronicleEngineEndpoint.class);
     }
 
     public ChronicleEngineComponent(CamelContext context) {
-        super(context, ChronicleEngineEnpoint.class);
+        super(context, ChronicleEngineEndpoint.class);
     }
 
     @Override
@@ -45,6 +45,6 @@ public class ChronicleEngineComponent extends UriEndpointComponent {
 
         setProperties(configuration, parameters);
 
-        return new ChronicleEngineEnpoint(uri, this, configuration);
+        return new ChronicleEngineEndpoint(uri, this, configuration);
     }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/2bbc1368/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConsumer.java
b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConsumer.java
index 4cf79d4..52bd453 100644
--- a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConsumer.java
+++ b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineConsumer.java
@@ -38,7 +38,7 @@ public class ChronicleEngineConsumer extends DefaultConsumer {
     private final String path;
     private AssetTree client;
 
-    public ChronicleEngineConsumer(ChronicleEngineEnpoint endpoint, Processor processor)
{
+    public ChronicleEngineConsumer(ChronicleEngineEndpoint endpoint, Processor processor)
{
         super(endpoint, processor);
 
         this.path = endpoint.getPath();
@@ -50,7 +50,7 @@ public class ChronicleEngineConsumer extends DefaultConsumer {
             throw new IllegalStateException("AssetTree already configured");
         }
 
-        ChronicleEngineEnpoint endpoint = (ChronicleEngineEnpoint)getEndpoint();
+        ChronicleEngineEndpoint endpoint = (ChronicleEngineEndpoint)getEndpoint();
         ChronicleEngineConfiguration conf = endpoint.getConfiguration();
         client = endpoint.createRemoteAssetTree();
 

http://git-wip-us.apache.org/repos/asf/camel/blob/2bbc1368/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineEndpoint.java
b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineEndpoint.java
new file mode 100644
index 0000000..8939a3c
--- /dev/null
+++ b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineEndpoint.java
@@ -0,0 +1,96 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.chronicle.engine;
+
+import net.openhft.chronicle.engine.api.tree.AssetTree;
+import net.openhft.chronicle.engine.tree.VanillaAssetTree;
+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.UriPath;
+import org.apache.camel.util.ObjectHelper;
+
+
+@UriEndpoint(scheme = "chronicle-engine", title = "Chronicle Engine", syntax = "chronicle-engine:addresses/path",
consumerClass = ChronicleEngineConsumer.class, label = "Chronicle")
+public class ChronicleEngineEndpoint extends DefaultEndpoint {
+    private final ChronicleEngineConfiguration configuration;
+
+    @UriPath(description = "engine path")
+    @Metadata(required = "true")
+    private final String path;
+
+    public ChronicleEngineEndpoint(String uri, ChronicleEngineComponent component, ChronicleEngineConfiguration
configuration) throws Exception {
+        super(uri, component);
+
+        ObjectHelper.notNull(configuration.getCamelContext(), "camelContext");
+        ObjectHelper.notNull(configuration.getAddresses(), "addresses");
+        ObjectHelper.notNull(configuration.getPath(), "path");
+        ObjectHelper.notNull(configuration.getWireType(), "wireType");
+
+        this.configuration = configuration;
+        this.path = configuration.getPath();
+    }
+
+    @Override
+    public boolean isSingleton() {
+        return true;
+    }
+
+    @Override
+    public Producer createProducer() throws Exception {
+        return new ChronicleEngineProducer(this);
+    }
+
+    @Override
+    public Consumer createConsumer(Processor processor) throws Exception {
+        return new ChronicleEngineConsumer(this, processor);
+    }
+
+    @Override
+    protected void doStart() throws Exception {
+    }
+
+    @Override
+    protected void doStop() throws Exception {
+    }
+
+    // ****************************
+    // Helpers
+    // ****************************
+
+    protected ChronicleEngineConfiguration getConfiguration() {
+        return configuration;
+    }
+
+    protected String getPath() {
+        return this.path;
+    }
+
+    protected String getUri() {
+        return configuration.isPersistent()
+            ? configuration.getPath()
+            : configuration.getPath() + "?dontPersist=true";
+    }
+
+    protected AssetTree createRemoteAssetTree() {
+        return new VanillaAssetTree()
+            .forRemoteAccess(configuration.getAddresses(), configuration.getWireType());
+    }
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/2bbc1368/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineEnpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineEnpoint.java
b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineEnpoint.java
deleted file mode 100644
index 04180c8..0000000
--- a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineEnpoint.java
+++ /dev/null
@@ -1,96 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.chronicle.engine;
-
-import net.openhft.chronicle.engine.api.tree.AssetTree;
-import net.openhft.chronicle.engine.tree.VanillaAssetTree;
-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.UriPath;
-import org.apache.camel.util.ObjectHelper;
-
-
-@UriEndpoint(scheme = "chronicle-engine", title = "Chronicle Engine", syntax = "chronicle-engine:addresses/path",
consumerClass = ChronicleEngineConsumer.class, label = "Chronicle")
-public class ChronicleEngineEnpoint extends DefaultEndpoint {
-    private final ChronicleEngineConfiguration configuration;
-
-    @UriPath(description = "engine path")
-    @Metadata(required = "true")
-    private final String path;
-
-    public ChronicleEngineEnpoint(String uri, ChronicleEngineComponent component, ChronicleEngineConfiguration
configuration) throws Exception {
-        super(uri, component);
-
-        ObjectHelper.notNull(configuration.getCamelContext(), "camelContext");
-        ObjectHelper.notNull(configuration.getAddresses(), "addresses");
-        ObjectHelper.notNull(configuration.getPath(), "path");
-        ObjectHelper.notNull(configuration.getWireType(), "wireType");
-
-        this.configuration = configuration;
-        this.path = configuration.getPath();
-    }
-
-    @Override
-    public boolean isSingleton() {
-        return true;
-    }
-
-    @Override
-    public Producer createProducer() throws Exception {
-        return new ChronicleEngineProducer(this);
-    }
-
-    @Override
-    public Consumer createConsumer(Processor processor) throws Exception {
-        return new ChronicleEngineConsumer(this, processor);
-    }
-
-    @Override
-    protected void doStart() throws Exception {
-    }
-
-    @Override
-    protected void doStop() throws Exception {
-    }
-
-    // ****************************
-    // Helpers
-    // ****************************
-
-    protected ChronicleEngineConfiguration getConfiguration() {
-        return configuration;
-    }
-
-    protected String getPath() {
-        return this.path;
-    }
-
-    protected String getUri() {
-        return configuration.isPersistent()
-            ? configuration.getPath()
-            : configuration.getPath() + "?dontPersist=true";
-    }
-
-    protected AssetTree createRemoteAssetTree() {
-        return new VanillaAssetTree()
-            .forRemoteAccess(configuration.getAddresses(), configuration.getWireType());
-    }
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/2bbc1368/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
index 4473031..9d41799 100644
--- a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
+++ b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
@@ -40,7 +40,7 @@ public class ChronicleEngineProducer extends HeaderSelectorProducer {
     private WeakRef<QueueView<Object, Object>> queueView;
     private AssetTree client;
 
-    public ChronicleEngineProducer(ChronicleEngineEnpoint endpoint) {
+    public ChronicleEngineProducer(ChronicleEngineEndpoint endpoint) {
         super(endpoint, ChronicleEngineConstants.ACTION, endpoint.getConfiguration().getAction());
 
         this.uri = endpoint.getUri();
@@ -62,7 +62,7 @@ public class ChronicleEngineProducer extends HeaderSelectorProducer {
             throw new IllegalStateException("AssetTree already configured");
         }
 
-        client = ((ChronicleEngineEnpoint)getEndpoint()).createRemoteAssetTree();
+        client = ((ChronicleEngineEndpoint)getEndpoint()).createRemoteAssetTree();
     }
 
     @Override

http://git-wip-us.apache.org/repos/asf/camel/blob/2bbc1368/components/pom.xml
----------------------------------------------------------------------
diff --git a/components/pom.xml b/components/pom.xml
index 6882f95..a1b023d 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -97,6 +97,7 @@
     <module>camel-cassandraql</module>
     <module>camel-castor</module>
     <module>camel-cdi</module>
+    <module>camel-chronicle</module>
     <module>camel-chunk</module>
     <module>camel-cm-sms</module>
     <module>camel-cmis</module>


Mime
View raw message