This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 20238db Fixed CS
20238db is described below
commit 20238dbe54a9f762e952bcc45e811ad32161be16
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Nov 22 09:47:18 2019 +0100
Fixed CS
---
.../org/apache/camel/component/iota/IOTAEndpoint.java | 1 -
.../org/apache/camel/component/iota/IOTAProducer.java | 15 ++++++---------
.../java/org/apache/camel/component/jms/JmsComponent.java | 1 +
.../xslt/TransformerFactoryConfigurationStrategy.java | 2 +-
4 files changed, 8 insertions(+), 11 deletions(-)
diff --git
a/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAEndpoint.java
b/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAEndpoint.java
index cb6a252..b35ae39 100644
---
a/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAEndpoint.java
+++
b/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAEndpoint.java
@@ -26,7 +26,6 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
-
import org.iota.jota.IotaAPI;
/**
diff --git
a/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAProducer.java
b/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAProducer.java
index 2cb15d8..8f4f75b 100644
---
a/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAProducer.java
+++
b/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAProducer.java
@@ -19,15 +19,15 @@ package org.apache.camel.component.iota;
import java.util.ArrayList;
import java.util.List;
+import org.apache.camel.Exchange;
+import org.apache.camel.support.DefaultProducer;
+import org.apache.commons.lang3.StringUtils;
import org.iota.jota.builder.AddressRequest;
import org.iota.jota.dto.response.GetNewAddressResponse;
import org.iota.jota.dto.response.GetTransferResponse;
import org.iota.jota.dto.response.SendTransferResponse;
import org.iota.jota.model.Transfer;
import org.iota.jota.utils.TrytesConverter;
-import org.apache.camel.Exchange;
-import org.apache.camel.support.DefaultProducer;
-import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -52,19 +52,15 @@ public class IOTAProducer extends DefaultProducer {
}
if
(endpoint.getOperation().equals(IOTAConstants.SEND_TRANSFER_OPERATION)) {
-
String address =
exchange.getIn().getHeader(IOTAConstants.TO_ADDRESS_HEADER, String.class);
Integer value =
exchange.getIn().getHeader(IOTAConstants.VALUE_HEADER, Integer.class);
value = value != null ? value : 0;
String tag = StringUtils.rightPad(endpoint.getTag(),
IOTAConstants.TAG_LENGTH, '9');
-
String message =
TrytesConverter.asciiToTrytes(exchange.getIn().getBody(String.class));
if (LOG.isDebugEnabled()) {
- // LOG.debug("seed {}", seed);
- LOG.debug("endpoint: security level {} depth {}
minWeightMagnitude {} tag {} ", endpoint.getSecurityLevel(),
endpoint.getDepth(), endpoint.getMinWeightMagnitude(),
- tag);
+ LOG.debug("endpoint: security level {} depth {}
minWeightMagnitude {} tag {} ", endpoint.getSecurityLevel(),
endpoint.getDepth(), endpoint.getMinWeightMagnitude(), tag);
LOG.debug("Sending value {} with message {} to address {}",
value, message, address);
}
@@ -75,7 +71,6 @@ public class IOTAProducer extends DefaultProducer {
exchange.getIn().setBody(response.getTransactions());
} else if
(endpoint.getOperation().equals(IOTAConstants.GET_NEW_ADDRESS_OPERATION)) {
-
Integer index =
exchange.getIn().getHeader(IOTAConstants.ADDRESS_INDEX_HEADER, Integer.class);
AddressRequest addressRequest = new AddressRequest.Builder(seed,
endpoint.getSecurityLevel())
@@ -83,6 +78,7 @@ public class IOTAProducer extends DefaultProducer {
.checksum(true)
.amount(1)
.build();
+
GetNewAddressResponse response =
endpoint.getApiClient().generateNewAddresses(addressRequest);
exchange.getIn().setBody(response.getAddresses());
} else if
(endpoint.getOperation().equals(IOTAConstants.GET_TRANSFERS_OPERATION)) {
@@ -90,6 +86,7 @@ public class IOTAProducer extends DefaultProducer {
Integer endIdx =
exchange.getIn().getHeader(IOTAConstants.ADDRESS_END_INDEX_HEADER,
Integer.class);
GetTransferResponse response =
endpoint.getApiClient().getTransfers(seed, endpoint.getSecurityLevel(),
startIdx, endIdx, true);
+
exchange.getIn().setBody(response.getTransfers());
}
}
diff --git
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
index 6b50499..5c37b97 100644
---
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
+++
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.jms;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ExecutorService;
+
import javax.jms.ConnectionFactory;
import javax.jms.ExceptionListener;
import javax.jms.Message;
diff --git
a/components/camel-xslt/src/main/java/org/apache/camel/component/xslt/TransformerFactoryConfigurationStrategy.java
b/components/camel-xslt/src/main/java/org/apache/camel/component/xslt/TransformerFactoryConfigurationStrategy.java
index 6c31086..feab6b2 100644
---
a/components/camel-xslt/src/main/java/org/apache/camel/component/xslt/TransformerFactoryConfigurationStrategy.java
+++
b/components/camel-xslt/src/main/java/org/apache/camel/component/xslt/TransformerFactoryConfigurationStrategy.java
@@ -29,5 +29,5 @@ public interface TransformerFactoryConfigurationStrategy {
* @param factory the {@link TransformerFactory} to configure
* @param endpoint the {@link XsltEndpoint} owning the given {@code
factory}
*/
- public void configure(TransformerFactory factory, XsltEndpoint endpoint);
+ void configure(TransformerFactory factory, XsltEndpoint endpoint);
}
