You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pa...@apache.org on 2018/09/06 18:32:53 UTC
[camel] branch master updated: Remove trailing blanks of log
messages
This is an automated email from the ASF dual-hosted git repository.
pascalschumacher 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 46d7993 Remove trailing blanks of log messages
46d7993 is described below
commit 46d7993fd64d2203fc06a715c2e819da267ed6ae
Author: Pascal Schumacher <pa...@gmx.net>
AuthorDate: Thu Sep 6 20:32:35 2018 +0200
Remove trailing blanks of log messages
---
.../main/java/org/apache/camel/component/file/FileOperations.java | 8 ++++----
.../apache/camel/component/properties/PropertiesComponent.java | 4 ++--
.../src/main/java/org/apache/camel/component/ahc/AhcProducer.java | 2 +-
.../org/apache/camel/component/asterisk/AsteriskProducer.java | 2 +-
.../camel/component/atmosphere/websocket/WebsocketProducer.java | 2 +-
.../apache/camel/component/atomix/cluster/AtomixClusterView.java | 2 +-
.../processor/aggregate/CaffeineAggregationRepository.java | 2 +-
.../aggregate/cassandra/CassandraAggregationRepository.java | 4 ++--
.../apache/camel/component/crypto/cms/sig/SignedDataVerifier.java | 2 +-
.../digitalocean/producer/DigitalOceanBlockStoragesProducer.java | 2 +-
.../digitalocean/producer/DigitalOceanDropletsProducer.java | 8 ++++----
.../digitalocean/producer/DigitalOceanFloatingIPsProducer.java | 8 ++++----
.../component/digitalocean/producer/DigitalOceanKeysProducer.java | 4 ++--
.../ehcache/processor/aggregate/EhcacheAggregationRepository.java | 2 +-
.../org/apache/camel/component/grpc/GrpcProducerSyncTest.java | 2 +-
.../main/java/org/apache/camel/component/hl7/HL7MLLPDecoder.java | 2 +-
.../processor/aggregate/InfinispanLocalAggregationRepository.java | 2 +-
.../aggregate/InfinispanRemoteAggregationRepository.java | 2 +-
.../main/java/org/apache/camel/component/kafka/KafkaConsumer.java | 2 +-
.../apache/camel/component/sjms/consumer/InOutMessageHandler.java | 2 +-
.../camel/processor/aggregate/tarfile/TarAggregationStrategy.java | 2 +-
.../component/xmlsecurity/processor/XmlSignatureProcessor.java | 2 +-
.../camel/component/xmlsecurity/processor/XmlSignerProcessor.java | 2 +-
.../src/main/java/org/apache/camel/zipkin/ZipkinTracer.java | 2 +-
24 files changed, 36 insertions(+), 36 deletions(-)
diff --git a/camel-core/src/main/java/org/apache/camel/component/file/FileOperations.java b/camel-core/src/main/java/org/apache/camel/component/file/FileOperations.java
index 415f60b..b193293 100644
--- a/camel-core/src/main/java/org/apache/camel/component/file/FileOperations.java
+++ b/camel-core/src/main/java/org/apache/camel/component/file/FileOperations.java
@@ -115,7 +115,7 @@ public class FileOperations implements GenericFileOperations<File> {
if (!subDir.exists()) {
if (subDir.mkdir()) {
if (LOG.isTraceEnabled()) {
- LOG.trace("Setting chmod: {} on directory: {} ", PosixFilePermissions.toString(permissions), subDir);
+ LOG.trace("Setting chmod: {} on directory: {}", PosixFilePermissions.toString(permissions), subDir);
}
Files.setPosixFilePermissions(subDir.toPath(), permissions);
} else {
@@ -287,7 +287,7 @@ public class FileOperations implements GenericFileOperations<File> {
Set<PosixFilePermission> permissions = endpoint.getPermissions();
if (!permissions.isEmpty()) {
if (LOG.isTraceEnabled()) {
- LOG.trace("Setting chmod: {} on file: {} ", PosixFilePermissions.toString(permissions), file);
+ LOG.trace("Setting chmod: {} on file: {}", PosixFilePermissions.toString(permissions), file);
}
Files.setPosixFilePermissions(file.toPath(), permissions);
}
@@ -308,7 +308,7 @@ public class FileOperations implements GenericFileOperations<File> {
Set<PosixFilePermission> permissions = endpoint.getPermissions();
if (!permissions.isEmpty()) {
if (LOG.isTraceEnabled()) {
- LOG.trace("Setting chmod: {} on file: {} ", PosixFilePermissions.toString(permissions), file);
+ LOG.trace("Setting chmod: {} on file: {}", PosixFilePermissions.toString(permissions), file);
}
Files.setPosixFilePermissions(file.toPath(), permissions);
}
@@ -341,7 +341,7 @@ public class FileOperations implements GenericFileOperations<File> {
Set<PosixFilePermission> permissions = endpoint.getPermissions();
if (!permissions.isEmpty()) {
if (LOG.isTraceEnabled()) {
- LOG.trace("Setting chmod: {} on file: {} ", PosixFilePermissions.toString(permissions), file);
+ LOG.trace("Setting chmod: {} on file: {}", PosixFilePermissions.toString(permissions), file);
}
Files.setPosixFilePermissions(file.toPath(), permissions);
}
diff --git a/camel-core/src/main/java/org/apache/camel/component/properties/PropertiesComponent.java b/camel-core/src/main/java/org/apache/camel/component/properties/PropertiesComponent.java
index 38527c8..005d662 100644
--- a/camel-core/src/main/java/org/apache/camel/component/properties/PropertiesComponent.java
+++ b/camel-core/src/main/java/org/apache/camel/component/properties/PropertiesComponent.java
@@ -543,11 +543,11 @@ public class PropertiesComponent extends UriEndpointComponent {
List<PropertiesLocation> answer = new ArrayList<>();
for (PropertiesLocation location : locations) {
- LOG.trace("Parsing location: {} ", location);
+ LOG.trace("Parsing location: {}", location);
try {
String path = FilePathResolver.resolvePath(location.getPath());
- LOG.debug("Parsed location: {} ", path);
+ LOG.debug("Parsed location: {}", path);
if (ObjectHelper.isNotEmpty(path)) {
answer.add(new PropertiesLocation(
location.getResolver(),
diff --git a/components/camel-ahc/src/main/java/org/apache/camel/component/ahc/AhcProducer.java b/components/camel-ahc/src/main/java/org/apache/camel/component/ahc/AhcProducer.java
index cc02349..b911ba7 100644
--- a/components/camel-ahc/src/main/java/org/apache/camel/component/ahc/AhcProducer.java
+++ b/components/camel-ahc/src/main/java/org/apache/camel/component/ahc/AhcProducer.java
@@ -51,7 +51,7 @@ public class AhcProducer extends DefaultAsyncProducer {
try {
// AHC supports async processing
Request request = getEndpoint().getBinding().prepareRequest(getEndpoint(), exchange);
- log.debug("Executing request {} ", request);
+ log.debug("Executing request {}", request);
client.executeRequest(request, new AhcAsyncHandler(exchange, callback, request.getUrl(), getEndpoint().getBufferSize()));
return false;
} catch (Exception e) {
diff --git a/components/camel-asterisk/src/main/java/org/apache/camel/component/asterisk/AsteriskProducer.java b/components/camel-asterisk/src/main/java/org/apache/camel/component/asterisk/AsteriskProducer.java
index 5537c59..eaff92e 100644
--- a/components/camel-asterisk/src/main/java/org/apache/camel/component/asterisk/AsteriskProducer.java
+++ b/components/camel-asterisk/src/main/java/org/apache/camel/component/asterisk/AsteriskProducer.java
@@ -70,7 +70,7 @@ public class AsteriskProducer extends DefaultProducer {
// Action must be set
ObjectHelper.notNull(action, "action");
- LOG.debug("Send action {} ", action);
+ LOG.debug("Send action {}", action);
ManagerAction managerAction = action.apply(exchange);
ManagerResponse managerResponse = connection.sendAction(managerAction);
diff --git a/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketProducer.java b/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketProducer.java
index 14b4875..342c851 100644
--- a/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketProducer.java
+++ b/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketProducer.java
@@ -62,7 +62,7 @@ public class WebsocketProducer extends DefaultProducer {
|| message instanceof Reader || message instanceof InputStream)) {
// fallback to use String
if (LOG.isInfoEnabled()) {
- LOG.info("Using String for unexpected message type {} ", message.getClass());
+ LOG.info("Using String for unexpected message type {}", message.getClass());
}
message = in.getBody(String.class);
}
diff --git a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterView.java b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterView.java
index 6f64a42..6305944 100644
--- a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterView.java
+++ b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterView.java
@@ -178,7 +178,7 @@ final class AtomixClusterView extends AbstractCamelClusterView {
if (member == null && group != null) {
String id = getClusterService().getId();
if (ObjectHelper.isEmpty(id) || configuration.isEphemeral()) {
- LOGGER.debug("Joining group: {} ", group);
+ LOGGER.debug("Joining group: {}", group);
member = group.join().join();
LOGGER.debug("Group {} joined with id {}", group, member.id());
} else {
diff --git a/components/camel-caffeine/src/main/java/org/apache/camel/component/caffeine/processor/aggregate/CaffeineAggregationRepository.java b/components/camel-caffeine/src/main/java/org/apache/camel/component/caffeine/processor/aggregate/CaffeineAggregationRepository.java
index 702a8e6..8c4624d 100644
--- a/components/camel-caffeine/src/main/java/org/apache/camel/component/caffeine/processor/aggregate/CaffeineAggregationRepository.java
+++ b/components/camel-caffeine/src/main/java/org/apache/camel/component/caffeine/processor/aggregate/CaffeineAggregationRepository.java
@@ -143,7 +143,7 @@ public class CaffeineAggregationRepository extends ServiceSupport implements Rec
@Override
public void remove(CamelContext camelContext, String key, Exchange exchange) {
- LOG.trace("Removing an exchange with ID {} for key {} ", exchange.getExchangeId(), key);
+ LOG.trace("Removing an exchange with ID {} for key {}", exchange.getExchangeId(), key);
cache.invalidate(key);
}
diff --git a/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepository.java b/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepository.java
index 8345cb1..d49d281 100644
--- a/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepository.java
+++ b/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepository.java
@@ -217,7 +217,7 @@ public class CassandraAggregationRepository extends ServiceSupport implements Re
@Override
public Exchange get(CamelContext camelContext, String key) {
Object[] pkValues = getPKValues(key);
- LOGGER.debug("Selecting key {} ", pkValues);
+ LOGGER.debug("Selecting key {}", pkValues);
Row row = getSession().execute(selectStatement.bind(pkValues)).one();
Exchange exchange = null;
if (row != null) {
@@ -254,7 +254,7 @@ public class CassandraAggregationRepository extends ServiceSupport implements Re
if (row.getString(exchangeIdColumn).equals(exchangeId)) {
String key = row.getString(keyColumn);
Object[] cqlParams = append(getPKValues(key), exchangeId);
- LOGGER.debug("Deleting If Id {} ", cqlParams);
+ LOGGER.debug("Deleting If Id {}", cqlParams);
getSession().execute(deleteIfIdStatement.bind(cqlParams));
}
}
diff --git a/components/camel-crypto-cms/src/main/java/org/apache/camel/component/crypto/cms/sig/SignedDataVerifier.java b/components/camel-crypto-cms/src/main/java/org/apache/camel/component/crypto/cms/sig/SignedDataVerifier.java
index 4979848..7382012 100644
--- a/components/camel-crypto-cms/src/main/java/org/apache/camel/component/crypto/cms/sig/SignedDataVerifier.java
+++ b/components/camel-crypto-cms/src/main/java/org/apache/camel/component/crypto/cms/sig/SignedDataVerifier.java
@@ -135,7 +135,7 @@ public class SignedDataVerifier extends CryptoCmsUnmarshaller {
int i = 0;
for (SignerInformation signer : signers.getSigners()) {
i++;
- LOG.debug(" Signer {}: {} ", new Object[] {i, signerInformationToString(signer)});
+ LOG.debug(" Signer {}: {}", new Object[] {i, signerInformationToString(signer)});
if (signer.getSignedAttributes() != null) {
@SuppressWarnings("unchecked")
Hashtable<String, Attribute> authAttTable = signer.getSignedAttributes().toHashtable();
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanBlockStoragesProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanBlockStoragesProducer.java
index f6f9530..b82fbbe 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanBlockStoragesProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanBlockStoragesProducer.java
@@ -119,7 +119,7 @@ public class DigitalOceanBlockStoragesProducer extends DigitalOceanProducer {
}
volume = getEndpoint().getDigitalOceanClient().createVolume(volume);
- LOG.trace("Volume created {} ", volume);
+ LOG.trace("Volume created {}", volume);
exchange.getOut().setBody(volume);
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanDropletsProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanDropletsProducer.java
index 5550726..3a36fe8 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanDropletsProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanDropletsProducer.java
@@ -158,7 +158,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
private void getDroplet(Exchange exchange) throws Exception {
Droplet droplet = getEndpoint().getDigitalOceanClient().getDropletInfo(dropletId);
- LOG.trace("Droplet {} ", droplet);
+ LOG.trace("Droplet {}", droplet);
exchange.getOut().setBody(droplet);
}
@@ -208,7 +208,7 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
private void deleteDroplet(Exchange exchange) throws Exception {
Delete delete = getEndpoint().getDigitalOceanClient().deleteDroplet(dropletId);
- LOG.trace("Delete Droplet {} ", delete);
+ LOG.trace("Delete Droplet {}", delete);
exchange.getOut().setBody(delete);
}
@@ -268,12 +268,12 @@ public class DigitalOceanDropletsProducer extends DigitalOceanProducer {
if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(DigitalOceanHeaders.NAMES))) {
droplet.setNames((List<String>) in.getHeader(DigitalOceanHeaders.NAMES));
Droplets droplets = getEndpoint().getDigitalOceanClient().createDroplets(droplet);
- LOG.trace("Droplets created {} ", droplets);
+ LOG.trace("Droplets created {}", droplets);
exchange.getOut().setBody(droplets.getDroplets());
} else if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(DigitalOceanHeaders.NAME))) {
droplet.setName(in.getHeader(DigitalOceanHeaders.NAME, String.class));
droplet = getEndpoint().getDigitalOceanClient().createDroplet(droplet);
- LOG.trace("Droplet created {} ", droplet);
+ LOG.trace("Droplet created {}", droplet);
exchange.getOut().setBody(droplet);
} else {
throw new IllegalArgumentException(DigitalOceanHeaders.NAMES + " or " + DigitalOceanHeaders.NAME + " must be specified");
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanFloatingIPsProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanFloatingIPsProducer.java
index fad44f2..5971b88 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanFloatingIPsProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanFloatingIPsProducer.java
@@ -99,7 +99,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
FloatingIP ip = getEndpoint().getDigitalOceanClient().getFloatingIPInfo(ipAddress);
- LOG.trace("Floating IP {} ", ip);
+ LOG.trace("Floating IP {}", ip);
exchange.getOut().setBody(ip);
}
@@ -113,7 +113,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
Delete delete = getEndpoint().getDigitalOceanClient().deleteFloatingIP(ipAddress);
- LOG.trace("Delete Floating IP {} ", delete);
+ LOG.trace("Delete Floating IP {}", delete);
exchange.getOut().setBody(delete);
}
@@ -131,7 +131,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
}
Action action = getEndpoint().getDigitalOceanClient().assignFloatingIP(dropletId, ipAddress);
- LOG.trace("Assign Floating IP to Droplet {} ", action);
+ LOG.trace("Assign Floating IP to Droplet {}", action);
exchange.getOut().setBody(action);
}
@@ -143,7 +143,7 @@ public class DigitalOceanFloatingIPsProducer extends DigitalOceanProducer {
}
Action action = getEndpoint().getDigitalOceanClient().unassignFloatingIP(ipAddress);
- LOG.trace("Unassign Floating IP {} ", action);
+ LOG.trace("Unassign Floating IP {}", action);
exchange.getOut().setBody(action);
}
diff --git a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanKeysProducer.java b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanKeysProducer.java
index f16866f..4a9d837 100644
--- a/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanKeysProducer.java
+++ b/components/camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/producer/DigitalOceanKeysProducer.java
@@ -94,7 +94,7 @@ public class DigitalOceanKeysProducer extends DigitalOceanProducer {
throw new IllegalArgumentException(DigitalOceanHeaders.ID + " or " + DigitalOceanHeaders.KEY_FINGERPRINT + " must be specified");
}
- LOG.trace("Delete Key {} ", delete);
+ LOG.trace("Delete Key {}", delete);
exchange.getOut().setBody(delete);
}
@@ -120,7 +120,7 @@ public class DigitalOceanKeysProducer extends DigitalOceanProducer {
}
key = getEndpoint().getDigitalOceanClient().createKey(key);
- LOG.trace("Key created {} ", key);
+ LOG.trace("Key created {}", key);
exchange.getOut().setBody(key);
}
diff --git a/components/camel-ehcache/src/main/java/org/apache/camel/component/ehcache/processor/aggregate/EhcacheAggregationRepository.java b/components/camel-ehcache/src/main/java/org/apache/camel/component/ehcache/processor/aggregate/EhcacheAggregationRepository.java
index 0219982..7c5af56 100644
--- a/components/camel-ehcache/src/main/java/org/apache/camel/component/ehcache/processor/aggregate/EhcacheAggregationRepository.java
+++ b/components/camel-ehcache/src/main/java/org/apache/camel/component/ehcache/processor/aggregate/EhcacheAggregationRepository.java
@@ -163,7 +163,7 @@ public class EhcacheAggregationRepository extends ServiceSupport implements Reco
@Override
public void remove(CamelContext camelContext, String key, Exchange exchange) {
- LOG.trace("Removing an exchange with ID {} for key {} ", exchange.getExchangeId(), key);
+ LOG.trace("Removing an exchange with ID {} for key {}", exchange.getExchangeId(), key);
cache.remove(key);
}
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSyncTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSyncTest.java
index aefe4e2..16e9e80 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSyncTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSyncTest.java
@@ -91,7 +91,7 @@ public class GrpcProducerSyncTest extends CamelTestSupport {
Object pongResponse = template.requestBody("direct:grpc-sync-sync", pingRequest);
assertEquals(((PongResponse)pongResponse).getPongId(), id);
}
- LOG.info("Multiple sync invocation time {} milliseconds, everage operations/sec {} ", stopwatch.stop().elapsed(TimeUnit.MILLISECONDS),
+ LOG.info("Multiple sync invocation time {} milliseconds, everage operations/sec {}", stopwatch.stop().elapsed(TimeUnit.MILLISECONDS),
Math.round(1000 * MULTIPLE_RUN_TEST_COUNT / stopwatch.elapsed(TimeUnit.MILLISECONDS)));
}
diff --git a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPDecoder.java b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPDecoder.java
index 2866aca..deffc3f 100644
--- a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPDecoder.java
+++ b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPDecoder.java
@@ -101,7 +101,7 @@ class HL7MLLPDecoder extends CumulativeProtocolDecoder {
// Could not find a complete message in the buffer.
// Reset to the initial position (just as nothing had been read yet)
// and return false so that this method is called again with more data.
- LOG.debug("No complete message yet at position {} ", in.position());
+ LOG.debug("No complete message yet at position {}", in.position());
state.markCurrent(in.position());
in.position(0);
}
diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/aggregate/InfinispanLocalAggregationRepository.java b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/aggregate/InfinispanLocalAggregationRepository.java
index 5785d1d..d18a58c 100644
--- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/aggregate/InfinispanLocalAggregationRepository.java
+++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/aggregate/InfinispanLocalAggregationRepository.java
@@ -78,7 +78,7 @@ public class InfinispanLocalAggregationRepository extends ServiceSupport impleme
@Override
public void remove(CamelContext camelContext, String key, Exchange exchange) {
- LOG.trace("Removing an exchange with ID {} for key {} ", exchange.getExchangeId(), key);
+ LOG.trace("Removing an exchange with ID {} for key {}", exchange.getExchangeId(), key);
cache.remove(key);
}
diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/aggregate/InfinispanRemoteAggregationRepository.java b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/aggregate/InfinispanRemoteAggregationRepository.java
index 73a9506..2afc4f7 100644
--- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/aggregate/InfinispanRemoteAggregationRepository.java
+++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/aggregate/InfinispanRemoteAggregationRepository.java
@@ -78,7 +78,7 @@ public class InfinispanRemoteAggregationRepository extends ServiceSupport implem
@Override
public void remove(CamelContext camelContext, String key, Exchange exchange) {
- LOG.trace("Removing an exchange with ID {} for key {} ", exchange.getExchangeId(), key);
+ LOG.trace("Removing an exchange with ID {} for key {}", exchange.getExchangeId(), key);
cache.remove(key);
}
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
index b18888c..e853ca2 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
@@ -389,7 +389,7 @@ public class KafkaConsumer extends DefaultConsumer {
} catch (Exception e) {
getExceptionHandler().handleException("Error consuming " + threadId + " from kafka topic", e);
} finally {
- log.debug("Closing {} ", threadId);
+ log.debug("Closing {}", threadId);
IOHelper.close(consumer);
}
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/InOutMessageHandler.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/InOutMessageHandler.java
index d5cc7f9..a8c0fc9 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/InOutMessageHandler.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/InOutMessageHandler.java
@@ -113,7 +113,7 @@ public class InOutMessageHandler extends AbstractMessageHandler {
}
if (log.isDebugEnabled()) {
- log.debug("SjmsMessageConsumer invoked for Exchange id:{} ", exchange.getExchangeId());
+ log.debug("SjmsMessageConsumer invoked for Exchange id:{}", exchange.getExchangeId());
}
}
diff --git a/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java b/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
index c11be84..bd2e58f 100644
--- a/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
+++ b/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
@@ -278,7 +278,7 @@ public class TarAggregationStrategy implements AggregationStrategy {
@Override
public void onComplete(Exchange exchange) {
- LOG.debug("Deleting tar file on completion: {} ", this.fileToDelete);
+ LOG.debug("Deleting tar file on completion: {}", this.fileToDelete);
FileUtil.deleteFile(this.fileToDelete);
}
}
diff --git a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/processor/XmlSignatureProcessor.java b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/processor/XmlSignatureProcessor.java
index 7b50d13..7f344a6 100644
--- a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/processor/XmlSignatureProcessor.java
+++ b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/processor/XmlSignatureProcessor.java
@@ -129,7 +129,7 @@ public abstract class XmlSignatureProcessor implements Processor {
if (schemaResourceUri == null) {
schemaResourceUri = getConfiguration().getSchemaResourceUri();
}
- LOG.debug("schema resource URI: {} ", getConfiguration().getSchemaResourceUri());
+ LOG.debug("schema resource URI: {}", getConfiguration().getSchemaResourceUri());
return schemaResourceUri;
}
diff --git a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/processor/XmlSignerProcessor.java b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/processor/XmlSignerProcessor.java
index b197402..257bba8 100644
--- a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/processor/XmlSignerProcessor.java
+++ b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/processor/XmlSignerProcessor.java
@@ -536,7 +536,7 @@ public class XmlSignerProcessor extends XmlSignatureProcessor {
// should not happen because has been checked before
throw new IllegalStateException("No element found for element ID " + elementId);
}
- LOG.debug("Sibling element of the detached XML Signature with reference URI {}: {} {} ",
+ LOG.debug("Sibling element of the detached XML Signature with reference URI {}: {} {}",
new Object[] {referenceUri, el.getLocalName(), el.getNamespaceURI() });
Element result = getParentElement(el);
if (result != null) {
diff --git a/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java b/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
index 7ee86f9..f069c78 100644
--- a/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
+++ b/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
@@ -356,7 +356,7 @@ public class ZipkinTracer extends ServiceSupport implements RoutePolicyFactory,
if (spanReporter == null) {
if (endpoint != null) {
- LOG.info("Configuring Zipkin URLConnectionSender using endpoint: {} ", endpoint);
+ LOG.info("Configuring Zipkin URLConnectionSender using endpoint: {}", endpoint);
spanReporter = AsyncReporter.create(URLConnectionSender.create(endpoint));
} else if (hostName != null && port > 0) {
LOG.info("Configuring Zipkin ScribeSpanCollector using host: {} and port: {}", hostName, port);