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 <[email protected]>
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);
