You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/07/26 09:14:40 UTC
[camel] branch master updated (8de48b3 -> 7af1dfc)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 8de48b3 Add XML schemas for release 2.20.4
new acac02a Camel-Nats: Polish
new 7af1dfc Camel-Nats: Fixed CS
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/camel/component/nats/NatsConsumer.java | 11 ++---------
.../java/org/apache/camel/component/nats/NatsProducer.java | 11 ++---------
2 files changed, 4 insertions(+), 18 deletions(-)
[camel] 02/02: Camel-Nats: Fixed CS
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7af1dfc30bedefea6bcd52907638ad64299d02c6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Jul 26 11:14:24 2018 +0200
Camel-Nats: Fixed CS
---
.../src/main/java/org/apache/camel/component/nats/NatsConsumer.java | 4 ++--
.../src/main/java/org/apache/camel/component/nats/NatsProducer.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java
index 8119b830..ccd65bb 100644
--- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java
+++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java
@@ -59,8 +59,8 @@ public class NatsConsumer extends DefaultConsumer {
executor = getEndpoint().createExecutor();
LOG.debug("Getting Nats Connection");
- connection = getEndpoint().getNatsConfiguration().getConnection() != null ?
- getEndpoint().getNatsConfiguration().getConnection():getEndpoint().getConnection();
+ connection = getEndpoint().getNatsConfiguration().getConnection() != null
+ ? getEndpoint().getNatsConfiguration().getConnection() : getEndpoint().getConnection();
executor.submit(new NatsConsumingTask(connection, getEndpoint().getNatsConfiguration()));
}
diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsProducer.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsProducer.java
index 715d853..edb9e85 100644
--- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsProducer.java
+++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsProducer.java
@@ -63,8 +63,8 @@ public class NatsProducer extends DefaultProducer {
LOG.debug("Starting Nats Producer");
LOG.debug("Getting Nats Connection");
- connection = getEndpoint().getNatsConfiguration().getConnection() != null ?
- getEndpoint().getNatsConfiguration().getConnection():getEndpoint().getConnection();
+ connection = getEndpoint().getNatsConfiguration().getConnection() != null
+ ? getEndpoint().getNatsConfiguration().getConnection() : getEndpoint().getConnection();
}
@Override
[camel] 01/02: Camel-Nats: Polish
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit acac02acd278a0ab355f2270be63dd0c5f7c996b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Jul 26 11:09:42 2018 +0200
Camel-Nats: Polish
---
.../main/java/org/apache/camel/component/nats/NatsConsumer.java | 7 -------
.../main/java/org/apache/camel/component/nats/NatsProducer.java | 7 -------
2 files changed, 14 deletions(-)
diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java
index e31924c..8119b830 100644
--- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java
+++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java
@@ -16,21 +16,14 @@
*/
package org.apache.camel.component.nats;
-import java.io.IOException;
-import java.security.GeneralSecurityException;
import java.time.Duration;
import java.util.concurrent.ExecutorService;
-import javax.net.ssl.SSLContext;
-
import io.nats.client.Connection;
import io.nats.client.Connection.Status;
import io.nats.client.Dispatcher;
import io.nats.client.Message;
import io.nats.client.MessageHandler;
-import io.nats.client.Nats;
-import io.nats.client.Options;
-import io.nats.client.Options.Builder;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsProducer.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsProducer.java
index 1812f60..715d853 100644
--- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsProducer.java
+++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsProducer.java
@@ -16,17 +16,10 @@
*/
package org.apache.camel.component.nats;
-import java.io.IOException;
-import java.security.GeneralSecurityException;
import java.time.Duration;
-import javax.net.ssl.SSLContext;
-
import io.nats.client.Connection;
import io.nats.client.Connection.Status;
-import io.nats.client.Nats;
-import io.nats.client.Options;
-import io.nats.client.Options.Builder;
import org.apache.camel.Exchange;
import org.apache.camel.impl.DefaultProducer;