This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 6d233b6 (chores) avoid creating arrays unnecessarily (#5702)
6d233b6 is described below
commit 6d233b66756a109d4c414b8b917bb9c95859d7d6
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Thu Jun 17 20:07:25 2021 +0200
(chores) avoid creating arrays unnecessarily (#5702)
components:
components/camel-couchdb components/camel-crypto,
components/camel-cxf-transport
components/camel-cxf, components/camel-dataset components/camel-dozer,
components/camel-guava-eventbus, components/camel-http-common,
components/camel-jms,
components/camel-jt400, components/camel-mina, components/camel-mongodb,
components/camel-netty, components/camel-quartz, components/camel-rabbitmq,
components/camel-sjms, components/camel-sql, components/camel-xmlsecurity,
components/camel-zookeeper, core/camel-api, core/camel-base-engine,
core/camel-core-processor, core/camel-support, core/camel-xml-jaxp,
tooling/maven,
---
.../component/couchdb/CouchDbChangesetTracker.java | 5 +----
.../camel/converter/crypto/PGPKeyAccessDataFormat.java | 4 ++--
.../cxf/common/message/DefaultCxfMessageMapper.java | 4 ++--
.../camel/component/cxf/jaxrs/SimpleCxfRsBinding.java | 9 ++++-----
.../camel/component/dataset/DataSetEndpoint.java | 5 ++---
.../converter/dozer/DozerTypeConverterLoader.java | 4 ++--
.../guava/eventbus/FilteringCamelEventHandler.java | 2 +-
.../org/apache/camel/http/common/CamelServlet.java | 4 ++--
.../org/apache/camel/component/jms/JmsBinding.java | 2 +-
.../org/apache/camel/component/jms/JmsProducer.java | 18 ++++++++----------
.../jms/reply/TemporaryQueueReplyManager.java | 2 +-
.../apache/camel/component/jt400/Jt400PgmProducer.java | 2 +-
.../org/apache/camel/component/mina/MinaConsumer.java | 2 +-
.../camel/component/mongodb/MongoDbEndpoint.java | 2 +-
.../ClientModeTCPNettyServerBootstrapFactory.java | 8 ++++----
.../camel/component/netty/NettyConfiguration.java | 9 ++++-----
.../camel/routepolicy/quartz/ScheduledRoutePolicy.java | 8 +++-----
.../camel/component/rabbitmq/RabbitMQComponent.java | 2 +-
.../org/apache/camel/component/sjms/SjmsProducer.java | 9 ++++-----
.../apache/camel/component/sjms/jms/JmsBinding.java | 2 +-
.../aggregate/jdbc/JdbcAggregationRepository.java | 2 +-
.../xmlsecurity/processor/XmlSignerProcessor.java | 2 +-
.../zookeeper/operations/DataChangedOperation.java | 2 +-
.../zookeeper/operations/ZooKeeperOperation.java | 2 +-
.../camel/support/jsse/KeyManagersParameters.java | 2 +-
.../apache/camel/support/jsse/KeyStoreParameters.java | 2 +-
.../camel/support/jsse/SecureRandomParameters.java | 2 +-
.../camel/support/jsse/TrustManagersParameters.java | 2 +-
.../impl/engine/DefaultPackageScanClassResolver.java | 2 +-
.../org/apache/camel/processor/CatchProcessor.java | 2 +-
.../apache/camel/support/DefaultExchangeHolder.java | 8 ++++----
.../org/apache/camel/support/IntrospectionSupport.java | 7 +++----
.../support/management/MixinRequiredModelMBean.java | 2 +-
.../org/apache/camel/converter/jaxp/XmlConverter.java | 2 +-
.../src/main/java/org/apache/camel/maven/RunMojo.java | 2 +-
35 files changed, 66 insertions(+), 78 deletions(-)
diff --git
a/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbChangesetTracker.java
b/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbChangesetTracker.java
index 14d145c..8b6a275 100644
---
a/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbChangesetTracker.java
+++
b/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbChangesetTracker.java
@@ -74,10 +74,7 @@ public class CouchDbChangesetTracker implements Runnable {
JsonObject doc = feed.getDoc();
Exchange exchange =
consumer.createExchange(lastSequence, feed.getId(), doc, feed.isDeleted());
- if (LOG.isTraceEnabled()) {
- LOG.trace("Created exchange [exchange={}, _id={},
seq={}",
- new Object[] { exchange, feed.getId(),
lastSequence });
- }
+ LOG.trace("Created exchange [exchange={}, _id={},
seq={}", exchange, feed.getId(), lastSequence);
try {
consumer.getProcessor().process(exchange);
diff --git
a/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/PGPKeyAccessDataFormat.java
b/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/PGPKeyAccessDataFormat.java
index db637a4..3a9c50c 100644
---
a/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/PGPKeyAccessDataFormat.java
+++
b/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/PGPKeyAccessDataFormat.java
@@ -125,10 +125,10 @@ public class PGPKeyAccessDataFormat extends
ServiceSupport implements DataFormat
private static final Logger LOG =
LoggerFactory.getLogger(PGPKeyAccessDataFormat.class);
- private static final List<String> SIGNATURE_VERIFICATION_OPTIONS =
Arrays.asList(new String[] {
+ private static final List<String> SIGNATURE_VERIFICATION_OPTIONS =
Arrays.asList(
SIGNATURE_VERIFICATION_OPTION_OPTIONAL,
SIGNATURE_VERIFICATION_OPTION_REQUIRED,
SIGNATURE_VERIFICATION_OPTION_IGNORE,
- SIGNATURE_VERIFICATION_OPTION_NO_SIGNATURE_ALLOWED });
+ SIGNATURE_VERIFICATION_OPTION_NO_SIGNATURE_ALLOWED);
private static final String BC = "BC";
private static final int BUFFER_SIZE = 16 * 1024;
diff --git
a/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/common/message/DefaultCxfMessageMapper.java
b/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/common/message/DefaultCxfMessageMapper.java
index ffcd81f..d1f3816 100644
---
a/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/common/message/DefaultCxfMessageMapper.java
+++
b/components/camel-cxf-transport/src/main/java/org/apache/camel/component/cxf/common/message/DefaultCxfMessageMapper.java
@@ -78,7 +78,7 @@ public class DefaultCxfMessageMapper implements
CxfMessageMapper {
LOG.trace(
"Processing {}, requestContentType = {}, acceptContentTypes =
{}, encoding = {}, path = {}, basePath = {}, verb = {}",
- new Object[] { camelExchange, requestContentType,
acceptContentTypes, enc, path, basePath, verb });
+ camelExchange, requestContentType, acceptContentTypes, enc,
path, basePath, verb);
return answer;
}
@@ -131,7 +131,7 @@ public class DefaultCxfMessageMapper implements
CxfMessageMapper {
if (value != null && !strategy.applyFilterToExternalHeaders(key,
value, exchange)) {
camelHeaders.put(Exchange.HTTP_RESPONSE_CODE, value);
LOG.trace("Populate header from CXF header={} value={} as {}",
- new Object[] { key, value, Exchange.HTTP_RESPONSE_CODE });
+ key, value, Exchange.HTTP_RESPONSE_CODE);
}
// propagate HTTP CONTENT_TYPE
diff --git
a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/SimpleCxfRsBinding.java
b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/SimpleCxfRsBinding.java
index 8b2a684..f78d65e 100644
---
a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/SimpleCxfRsBinding.java
+++
b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/SimpleCxfRsBinding.java
@@ -109,22 +109,21 @@ public class SimpleCxfRsBinding extends
DefaultCxfRsBinding {
/** The JAX-RS annotations to be injected as headers in the IN message */
private static final Set<Class<?>> HEADER_ANNOTATIONS =
Collections.unmodifiableSet(
new HashSet<>(
- Arrays.asList(new Class<?>[] {
+ Arrays.asList(
CookieParam.class,
FormParam.class,
PathParam.class,
HeaderParam.class,
MatrixParam.class,
- QueryParam.class })));
+ QueryParam.class)));
private static final Set<Class<?>> BINARY_ATTACHMENT_TYPES =
Collections.unmodifiableSet(
new HashSet<>(
- Arrays.asList(new Class<?>[] {
+ Arrays.asList(
Attachment.class,
DataHandler.class,
DataSource.class,
- InputStream.class,
- })));
+ InputStream.class)));
private static final Class<?>[] NO_PARAMETER_TYPES = null;
private static final Object[] NO_PARAMETERS = null;
diff --git
a/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
b/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
index bc53fdb..dd21dae 100644
---
a/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
+++
b/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
@@ -247,10 +247,9 @@ public class DataSetEndpoint extends MockEndpoint
implements Service {
if (log.isDebugEnabled()) {
if (copy.getIn().getHeader(Exchange.DATASET_INDEX) != null) {
log.debug("Received message: {} (DataSet index={}) = {}",
- new Object[] { index,
copy.getIn().getHeader(Exchange.DATASET_INDEX, Integer.class), copy });
+ index, copy.getIn().getHeader(Exchange.DATASET_INDEX,
Integer.class), copy);
} else {
- log.debug("Received message: {} = {}",
- new Object[] { index, copy });
+ log.debug("Received message: {} = {}", index, copy);
}
}
diff --git
a/components/camel-dozer/src/main/java/org/apache/camel/converter/dozer/DozerTypeConverterLoader.java
b/components/camel-dozer/src/main/java/org/apache/camel/converter/dozer/DozerTypeConverterLoader.java
index c556995..fdf988d 100644
---
a/components/camel-dozer/src/main/java/org/apache/camel/converter/dozer/DozerTypeConverterLoader.java
+++
b/components/camel-dozer/src/main/java/org/apache/camel/converter/dozer/DozerTypeConverterLoader.java
@@ -213,9 +213,9 @@ public class DozerTypeConverterLoader extends
ServiceSupport implements CamelCon
String dozerId, Class<?> to, Class<?> from) {
if (log.isInfoEnabled()) {
if (dozerId != null) {
- log.info("Added Dozer: {} as Camel type converter: {} -> {}",
new Object[] { dozerId, from, to });
+ log.info("Added Dozer: {} as Camel type converter: {} -> {}",
dozerId, from, to);
} else {
- log.info("Added Dozer as Camel type converter: {} -> {}", new
Object[] { from, to });
+ log.info("Added Dozer as Camel type converter: {} -> {}",
from, to);
}
}
diff --git
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/FilteringCamelEventHandler.java
b/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/FilteringCamelEventHandler.java
index c950d3f..fe27237 100644
---
a/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/FilteringCamelEventHandler.java
+++
b/components/camel-guava-eventbus/src/main/java/org/apache/camel/component/guava/eventbus/FilteringCamelEventHandler.java
@@ -45,7 +45,7 @@ public class FilteringCamelEventHandler extends
CamelEventHandler {
} else {
if (log.isDebugEnabled()) {
log.debug("Cannot process event: {} as its class type: {} is
not assignable with: {}",
- new Object[] { event, event.getClass().getName(),
eventClass.getName() });
+ event, event.getClass().getName(),
eventClass.getName());
}
}
}
diff --git
a/components/camel-http-common/src/main/java/org/apache/camel/http/common/CamelServlet.java
b/components/camel-http-common/src/main/java/org/apache/camel/http/common/CamelServlet.java
index 12d42f8..e9fdb71 100644
---
a/components/camel-http-common/src/main/java/org/apache/camel/http/common/CamelServlet.java
+++
b/components/camel-http-common/src/main/java/org/apache/camel/http/common/CamelServlet.java
@@ -454,7 +454,7 @@ public class CamelServlet extends HttpServlet implements
HttpRegistryProvider {
Thread.currentThread().setContextClassLoader(appCtxCl);
if (log.isTraceEnabled()) {
log.trace("Overrode TCCL for exchangeId {} to {} on thread {}",
- new Object[] { exchange.getExchangeId(), appCtxCl,
Thread.currentThread().getName() });
+ exchange.getExchangeId(), appCtxCl,
Thread.currentThread().getName());
}
return oldClassLoader;
}
@@ -471,7 +471,7 @@ public class CamelServlet extends HttpServlet implements
HttpRegistryProvider {
Thread.currentThread().setContextClassLoader(oldTccl);
if (log.isTraceEnabled()) {
log.trace("Restored TCCL for exchangeId {} to {} on thread {}",
- new String[] { exchange.getExchangeId(),
oldTccl.toString(), Thread.currentThread().getName() });
+ exchange.getExchangeId(), oldTccl,
Thread.currentThread().getName());
}
}
diff --git
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
index 2a95354..0eaf5f1 100644
---
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
+++
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
@@ -431,7 +431,7 @@ public class JmsBinding {
} else if (LOG.isDebugEnabled()) {
// okay the value is not a primitive or string so we cannot
sent it over the wire
LOG.debug("Ignoring non primitive header: {} of class: {} with
value: {}",
- new Object[] { headerName,
headerValue.getClass().getName(), headerValue });
+ headerName, headerValue.getClass().getName(),
headerValue);
}
}
}
diff --git
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
index 7818a69..f4b63a6 100644
---
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
+++
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
@@ -243,7 +243,7 @@ public class JmsProducer extends DefaultAsyncProducer {
if (LOG.isDebugEnabled()) {
LOG.debug("Using {}: {}, JMSReplyTo destination: {}, with
request timeout: {} ms.",
- new Object[] { correlationPropertyToUse,
correlationId, replyTo, timeout });
+ correlationPropertyToUse, correlationId, replyTo,
timeout);
}
LOG.trace("Created javax.jms.Message: {}", answer);
@@ -351,11 +351,10 @@ public class JmsProducer extends DefaultAsyncProducer {
if (jmsReplyTo != null && !(endpoint.isPreserveMessageQos() ||
endpoint.isExplicitQosEnabled())) {
// log at debug what we are doing, as higher level may
cause noise in production logs
// this behavior is also documented at the camel website
- if (LOG.isDebugEnabled()) {
- LOG.debug(
- "Disabling JMSReplyTo: {} for destination: {}.
Use preserveMessageQos=true to force Camel to keep the JMSReplyTo on endpoint:
{}",
- new Object[] { jmsReplyTo, to, endpoint });
- }
+ LOG.debug(
+ "Disabling JMSReplyTo: {} for destination: {}. Use
preserveMessageQos=true to force Camel to keep the JMSReplyTo on endpoint: {}",
+ jmsReplyTo, to, endpoint);
+
jmsReplyTo = null;
}
@@ -439,10 +438,9 @@ public class JmsProducer extends DefaultAsyncProducer {
if (endpoint.getDestinationResolver() != null) {
dest =
endpoint.getDestinationResolver().resolveDestinationName(session,
destinationName,
isPubSub);
- if (LOG.isDebugEnabled()) {
- LOG.debug("Resolved JMSReplyTo destination {} using
DestinationResolver {} as PubSubDomain {} -> {}",
- new Object[] { destinationName,
endpoint.getDestinationResolver(), isPubSub, dest });
- }
+
+ LOG.debug("Resolved JMSReplyTo destination {} using
DestinationResolver {} as PubSubDomain {} -> {}",
+ destinationName, endpoint.getDestinationResolver(),
isPubSub, dest);
}
if (dest == null) {
// must normalize the destination name
diff --git
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
index 2349a09..13b9abe 100644
---
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
+++
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
@@ -168,7 +168,7 @@ public class TemporaryQueueReplyManager extends
ReplyManagerSupport {
if (answer.getConcurrentConsumers() > 1) {
// log that we are using concurrent consumers
log.info("Using {}-{} concurrent consumers on {}",
- new Object[] { answer.getConcurrentConsumers(),
answer.getMaxConcurrentConsumers(), name });
+ answer.getConcurrentConsumers(),
answer.getMaxConcurrentConsumers(), name);
}
return answer;
}
diff --git
a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400PgmProducer.java
b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400PgmProducer.java
index bfb4316..2fb8a98 100644
---
a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400PgmProducer.java
+++
b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400PgmProducer.java
@@ -72,7 +72,7 @@ public class Jt400PgmProducer extends DefaultProducer {
if (LOG.isDebugEnabled()) {
LOG.trace(
"Starting to call PGM '{}' in host '{}' authentication
with the user '{}'",
- new Object[] { commandStr, iSeries.getSystemName(),
iSeries.getUserId() });
+ commandStr, iSeries.getSystemName(),
iSeries.getUserId());
}
boolean result = pgmCall.run();
diff --git
a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConsumer.java
b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConsumer.java
index e18d3d8..4cdbeb2 100644
---
a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConsumer.java
+++
b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConsumer.java
@@ -256,7 +256,7 @@ public class MinaConsumer extends DefaultConsumer {
addCodecFactory(service, codecFactory);
if (LOG.isDebugEnabled()) {
LOG.debug("{}: Using TextLineCodecFactory: {} using encoding:
{} line delimiter: {}({})",
- new Object[] { type, codecFactory, charset,
configuration.getTextlineDelimiter(), delimiter });
+ type, codecFactory, charset,
configuration.getTextlineDelimiter(), delimiter);
LOG.debug("Encoder maximum line length: {}. Decoder maximum
line length: {}",
codecFactory.getEncoderMaxLineLength(),
codecFactory.getDecoderMaxLineLength());
}
diff --git
a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
index f77f97d..8b62fbc 100644
---
a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
+++
b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
@@ -260,7 +260,7 @@ public class MongoDbEndpoint extends DefaultEndpoint {
LOG.debug("MongoDb component initialised and endpoint bound to
MongoDB collection with the following parameters. "
+ "Cluster description: {}, Db: {}, Collection: {}",
- new Object[] { mongoConnection.getClusterDescription(),
mongoDatabase.getName(), collection });
+ mongoConnection.getClusterDescription(),
mongoDatabase.getName(), collection);
try {
if (ObjectHelper.isNotEmpty(collectionIndex)) {
diff --git
a/components/camel-netty/src/main/java/org/apache/camel/component/netty/ClientModeTCPNettyServerBootstrapFactory.java
b/components/camel-netty/src/main/java/org/apache/camel/component/netty/ClientModeTCPNettyServerBootstrapFactory.java
index a9cf8aa..5bc48a8 100644
---
a/components/camel-netty/src/main/java/org/apache/camel/component/netty/ClientModeTCPNettyServerBootstrapFactory.java
+++
b/components/camel-netty/src/main/java/org/apache/camel/component/netty/ClientModeTCPNettyServerBootstrapFactory.java
@@ -136,10 +136,10 @@ public class ClientModeTCPNettyServerBootstrapFactory
extends ServiceSupport imp
clientBootstrap.handler(pipelineFactory);
ChannelFuture channelFuture
= clientBootstrap.connect(new
InetSocketAddress(configuration.getHost(), configuration.getPort()));
- if (LOG.isDebugEnabled()) {
- LOG.debug("Created new TCP client bootstrap connecting to {}:{}
with options: {}",
- new Object[] { configuration.getHost(),
configuration.getPort(), clientBootstrap });
- }
+
+ LOG.debug("Created new TCP client bootstrap connecting to {}:{} with
options: {}",
+ configuration.getHost(), configuration.getPort(),
clientBootstrap);
+
LOG.info("ClientModeServerBootstrap binding to {}:{}",
configuration.getHost(), configuration.getPort());
channel = openChannel(channelFuture);
}
diff --git
a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
index 37f4810..a53d56b 100644
---
a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
+++
b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
@@ -246,11 +246,10 @@ public class NettyConfiguration extends
NettyServerBootstrapConfiguration implem
ChannelHandlerFactories.newDelimiterBasedFrameDecoder(decoderMaxLineLength,
delimiters, protocol));
decoders.add(ChannelHandlerFactories.newStringDecoder(charset, protocol));
- if (LOG.isDebugEnabled()) {
- LOG.debug(
- "Using textline encoders and decoders with
charset: {}, delimiter: {} and decoderMaxLineLength: {}",
- new Object[] { charset, delimiter,
decoderMaxLineLength });
- }
+ LOG.debug(
+ "Using textline encoders and decoders with
charset: {}, delimiter: {} and decoderMaxLineLength: {}",
+ charset, delimiter, decoderMaxLineLength);
+
} else if ("udp".equalsIgnoreCase(protocol) &&
isUdpByteArrayCodec()) {
encoders.add(ChannelHandlerFactories.newByteArrayEncoder(protocol));
decoders.add(ChannelHandlerFactories.newByteArrayDecoder(protocol));
diff --git
a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicy.java
b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicy.java
index f1d1a99..6dbe7797 100644
---
a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicy.java
+++
b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicy.java
@@ -116,11 +116,9 @@ public abstract class ScheduledRoutePolicy extends
RoutePolicySupport
// check to see if the same job has already been setup through
another node of the cluster
JobDetail existingJobDetail =
getScheduler().getJobDetail(jobDetail.getKey());
if (jobDetail.equals(existingJobDetail)) {
- if (LOG.isInfoEnabled()) {
- LOG.info(
- "Skipping to schedule the job: {} for action: {}
on route {} as the job: {} already existing inside the cluster",
- new Object[] { jobDetail.getKey(), action,
route.getId(), existingJobDetail.getKey() });
- }
+ LOG.info(
+ "Skipping to schedule the job: {} for action: {} on
route {} as the job: {} already existing inside the cluster",
+ jobDetail.getKey(), action, route.getId(),
existingJobDetail.getKey());
// skip scheduling the same job again as one is already
existing for the same routeId and action
return;
diff --git
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQComponent.java
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQComponent.java
index e86f2dc..ca080ab 100644
---
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQComponent.java
+++
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQComponent.java
@@ -276,7 +276,7 @@ public class RabbitMQComponent extends DefaultComponent {
if (LOG.isDebugEnabled()) {
LOG.debug("Creating RabbitMQEndpoint with host {}:{} and
exchangeName: {}",
- new Object[] { endpoint.getHostname(),
endpoint.getPortNumber(), endpoint.getExchangeName() });
+ endpoint.getHostname(), endpoint.getPortNumber(),
endpoint.getExchangeName());
}
Map<String, Object> localArgs = new HashMap<>();
diff --git
a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
index ae70053..7474639 100644
---
a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
+++
b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
@@ -373,11 +373,10 @@ public class SjmsProducer extends DefaultAsyncProducer {
if (jmsReplyTo != null && !(endpoint.isPreserveMessageQos() ||
endpoint.isExplicitQosEnabled())) {
// log at debug what we are doing, as higher level may
cause noise in production logs
// this behavior is also documented at the camel website
- if (LOG.isDebugEnabled()) {
- LOG.debug(
- "Disabling JMSReplyTo: {} for destination: {}.
Use preserveMessageQos=true to force Camel to keep the JMSReplyTo on endpoint:
{}",
- new Object[] { jmsReplyTo, to, endpoint });
- }
+ LOG.debug(
+ "Disabling JMSReplyTo: {} for destination: {}. Use
preserveMessageQos=true to force Camel to keep the JMSReplyTo on endpoint: {}",
+ jmsReplyTo, to, endpoint);
+
jmsReplyTo = null;
}
diff --git
a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsBinding.java
b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsBinding.java
index bfd7c29..fe36a1e 100644
---
a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsBinding.java
+++
b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/JmsBinding.java
@@ -321,7 +321,7 @@ public class JmsBinding {
} else if (LOG.isDebugEnabled()) {
// okay the value is not a primitive or string so we cannot
sent it over the wire
LOG.debug("Ignoring non primitive header: {} of class: {} with
value: {}",
- new Object[] { headerName,
headerValue.getClass().getName(), headerValue });
+ headerName, headerValue.getClass().getName(),
headerValue);
}
}
}
diff --git
a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java
b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java
index 0915c09..cf573fb 100644
---
a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java
+++
b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java
@@ -398,7 +398,7 @@ public class JdbcAggregationRepository extends
ServiceSupport
final String confirmKey = exchangeId;
jdbcTemplate.update("DELETE FROM " +
getRepositoryNameCompleted() + " WHERE " + ID + " = ?",
- new Object[] { confirmKey });
+ confirmKey);
}
});
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 f67cae1..30055f0 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
@@ -542,7 +542,7 @@ public class XmlSignerProcessor extends
XmlSignatureProcessor {
throw new IllegalStateException("No element found for element ID "
+ elementId);
}
LOG.debug("Sibling element of the detached XML Signature with
reference URI {}: {} {}",
- new Object[] { referenceUri, el.getLocalName(),
el.getNamespaceURI() });
+ referenceUri, el.getLocalName(), el.getNamespaceURI());
Element result = getParentElement(el);
if (result != null) {
return result;
diff --git
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/operations/DataChangedOperation.java
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/operations/DataChangedOperation.java
index 36e90f1..53c9725 100644
---
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/operations/DataChangedOperation.java
+++
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/operations/DataChangedOperation.java
@@ -67,6 +67,6 @@ public class DataChangedOperation extends
FutureEventDrivenOperation<byte[]> {
@Override
public ZooKeeperOperation<?> createCopy() throws Exception {
return getClass().getConstructor(CONSTRUCTOR_ARGS)
- .newInstance(new Object[] { connection, node, getChangedData,
sendEmptyMessageOnDelete });
+ .newInstance(connection, node, getChangedData,
sendEmptyMessageOnDelete);
}
}
diff --git
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/operations/ZooKeeperOperation.java
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/operations/ZooKeeperOperation.java
index 52c214e..d3e0ebf 100644
---
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/operations/ZooKeeperOperation.java
+++
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/operations/ZooKeeperOperation.java
@@ -103,6 +103,6 @@ public abstract class ZooKeeperOperation<ResultType> {
// TODO slightly different to a clone as it uses the constructor
public ZooKeeperOperation<?> createCopy() throws Exception {
- return getClass().getConstructor(CONSTRUCTOR_ARGS).newInstance(new
Object[] { connection, node });
+ return
getClass().getConstructor(CONSTRUCTOR_ARGS).newInstance(connection, node);
}
}
diff --git
a/core/camel-api/src/main/java/org/apache/camel/support/jsse/KeyManagersParameters.java
b/core/camel-api/src/main/java/org/apache/camel/support/jsse/KeyManagersParameters.java
index 7dfdede..14b775f 100644
---
a/core/camel-api/src/main/java/org/apache/camel/support/jsse/KeyManagersParameters.java
+++
b/core/camel-api/src/main/java/org/apache/camel/support/jsse/KeyManagersParameters.java
@@ -92,7 +92,7 @@ public class KeyManagersParameters extends JsseParameters {
}
LOG.debug("KeyManagerFactory [{}], initialized from [{}], is using
provider [{}] and algorithm [{}].",
- new Object[] { kmf, this, kmf.getProvider(),
kmf.getAlgorithm() });
+ kmf, this, kmf.getProvider(), kmf.getAlgorithm());
char[] kmfPassword = null;
if (this.getKeyPassword() != null) {
diff --git
a/core/camel-api/src/main/java/org/apache/camel/support/jsse/KeyStoreParameters.java
b/core/camel-api/src/main/java/org/apache/camel/support/jsse/KeyStoreParameters.java
index fce3bd2..5575cdb 100644
---
a/core/camel-api/src/main/java/org/apache/camel/support/jsse/KeyStoreParameters.java
+++
b/core/camel-api/src/main/java/org/apache/camel/support/jsse/KeyStoreParameters.java
@@ -175,7 +175,7 @@ public class KeyStoreParameters extends JsseParameters {
}
LOG.debug("KeyStore [{}], initialized from [{}], is using provider
[{}], has type [{}], and contains aliases {}.",
- new Object[] { ks, this, ks.getProvider(), ks.getType(),
aliases });
+ ks, this, ks.getProvider(), ks.getType(), aliases);
}
return ks;
diff --git
a/core/camel-api/src/main/java/org/apache/camel/support/jsse/SecureRandomParameters.java
b/core/camel-api/src/main/java/org/apache/camel/support/jsse/SecureRandomParameters.java
index 8ec7b05..7126d60 100644
---
a/core/camel-api/src/main/java/org/apache/camel/support/jsse/SecureRandomParameters.java
+++
b/core/camel-api/src/main/java/org/apache/camel/support/jsse/SecureRandomParameters.java
@@ -62,7 +62,7 @@ public class SecureRandomParameters extends JsseParameters {
}
LOG.debug("SecureRandom [{}] is using provider [{}] and algorithm
[{}].",
- new Object[] { secureRandom, secureRandom.getProvider(),
secureRandom.getAlgorithm() });
+ secureRandom, secureRandom.getProvider(),
secureRandom.getAlgorithm());
return secureRandom;
}
diff --git
a/core/camel-api/src/main/java/org/apache/camel/support/jsse/TrustManagersParameters.java
b/core/camel-api/src/main/java/org/apache/camel/support/jsse/TrustManagersParameters.java
index cffa501..ea7823e 100644
---
a/core/camel-api/src/main/java/org/apache/camel/support/jsse/TrustManagersParameters.java
+++
b/core/camel-api/src/main/java/org/apache/camel/support/jsse/TrustManagersParameters.java
@@ -94,7 +94,7 @@ public class TrustManagersParameters extends JsseParameters {
}
LOG.debug("TrustManagerFactory [{}] is using provider [{}] and
algorithm [{}].",
- new Object[] { tmf, tmf.getProvider(), tmf.getAlgorithm()
});
+ tmf, tmf.getProvider(), tmf.getAlgorithm());
KeyStore ks = this.getKeyStore() == null ? null :
this.getKeyStore().createKeyStore();
tmf.init(ks);
diff --git
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultPackageScanClassResolver.java
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultPackageScanClassResolver.java
index 7611df3..b93ea83 100644
---
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultPackageScanClassResolver.java
+++
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultPackageScanClassResolver.java
@@ -164,7 +164,7 @@ public class DefaultPackageScanClassResolver extends
BasePackageScanResolver
protected void find(PackageScanFilter test, String packageName,
ClassLoader loader, Set<Class<?>> classes) {
if (log.isTraceEnabled()) {
log.trace("Searching for: {} in package: {} using classloader: {}",
- new Object[] { test, packageName,
loader.getClass().getName() });
+ test, packageName, loader.getClass().getName());
}
Enumeration<URL> urls;
diff --git
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/CatchProcessor.java
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/CatchProcessor.java
index b3ad6a6..88bbccf 100644
---
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/CatchProcessor.java
+++
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/CatchProcessor.java
@@ -110,7 +110,7 @@ public class CatchProcessor extends DelegateAsyncProcessor
implements Traceable,
if (LOG.isDebugEnabled()) {
LOG.debug("The exception is handled for the exception: {} caused
by: {}",
- new Object[] { e.getClass().getName(), e.getMessage() });
+ e.getClass().getName(), e.getMessage());
}
// emit event that the failure is being handled
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultExchangeHolder.java
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultExchangeHolder.java
index cca2643..2436f04 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultExchangeHolder.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultExchangeHolder.java
@@ -400,13 +400,13 @@ public class DefaultExchangeHolder implements
Serializable {
if (LOG.isDebugEnabled()) {
LOG.debug(
"Exchange {} containing key: {} with object: {} of
type: {} cannot be serialized, it will be excluded by the holder.",
- new Object[] { type, key, value,
ObjectHelper.classCanonicalName(value) });
+ type, key, value,
ObjectHelper.classCanonicalName(value));
}
} else {
// log regular at WARN level
LOG.warn(
"Exchange {} containing key: {} with object: {} of type:
{} cannot be serialized, it will be excluded by the holder.",
- new Object[] { type, key, value,
ObjectHelper.classCanonicalName(value) });
+ type, key, value, ObjectHelper.classCanonicalName(value));
}
}
@@ -414,7 +414,7 @@ public class DefaultExchangeHolder implements Serializable {
if (LOG.isDebugEnabled()) {
LOG.debug(
"Exchange {} containing key: {} with object: {} of type:
{} is not valid header type, it will be excluded by the holder.",
- new Object[] { type, key, value,
ObjectHelper.classCanonicalName(value) });
+ type, key, value, ObjectHelper.classCanonicalName(value));
}
}
@@ -422,7 +422,7 @@ public class DefaultExchangeHolder implements Serializable {
if (LOG.isDebugEnabled()) {
LOG.debug(
"Exchange {} containing key: {} with object: {} of type:
{} is not valid exchange property type, it will be excluded by the holder.",
- new Object[] { type, key, value,
ObjectHelper.classCanonicalName(value) });
+ type, key, value, ObjectHelper.classCanonicalName(value));
}
}
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/IntrospectionSupport.java
b/core/camel-support/src/main/java/org/apache/camel/support/IntrospectionSupport.java
index c057aa9..228b1f8 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/IntrospectionSupport.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/IntrospectionSupport.java
@@ -830,10 +830,9 @@ public final class IntrospectionSupport {
} catch (IllegalArgumentException e) {
typeConversionFailed = e;
}
- if (LOG.isTraceEnabled()) {
- LOG.trace("Setter \"{}\" with parameter type \"{}\" could not
be used for type conversions of {}",
- new Object[] { setter, parameterType, ref });
- }
+
+ LOG.trace("Setter \"{}\" with parameter type \"{}\" could not be
used for type conversions of {}",
+ setter, parameterType, ref);
}
if (typeConversionFailed != null && !isPropertyPlaceholder(context,
value)) {
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/management/MixinRequiredModelMBean.java
b/core/camel-support/src/main/java/org/apache/camel/support/management/MixinRequiredModelMBean.java
index d490792..e9a5b95 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/management/MixinRequiredModelMBean.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/management/MixinRequiredModelMBean.java
@@ -112,7 +112,7 @@ public class MixinRequiredModelMBean extends
RequiredModelMBean {
String answer = URISupport.sanitizeUri(value);
if (LOG.isTraceEnabled()) {
LOG.trace("Masking JMX operation: {}.{} value: {} -> {}",
- new Object[] { getMBeanInfo().getClassName(), opName,
value, answer });
+ getMBeanInfo().getClassName(), opName, value, answer);
}
return answer;
}
diff --git
a/core/camel-xml-jaxp/src/main/java/org/apache/camel/converter/jaxp/XmlConverter.java
b/core/camel-xml-jaxp/src/main/java/org/apache/camel/converter/jaxp/XmlConverter.java
index 6992a99..750b4e2 100644
---
a/core/camel-xml-jaxp/src/main/java/org/apache/camel/converter/jaxp/XmlConverter.java
+++
b/core/camel-xml-jaxp/src/main/java/org/apache/camel/converter/jaxp/XmlConverter.java
@@ -1090,7 +1090,7 @@ public class XmlConverter {
sfactory.setFeature("http://xml.org/sax/features/external-general-entities";,
false);
} catch (Exception e) {
LOG.warn("SAXParser doesn't support the feature {} with value {},
due to {}.",
- new Object[] {
"http://xml.org/sax/features/external-general-entities";, false, e.getMessage()
});
+ "http://xml.org/sax/features/external-general-entities";,
false, e.getMessage());
}
sfactory.setNamespaceAware(true);
return sfactory;
diff --git
a/tooling/maven/camel-maven-plugin/src/main/java/org/apache/camel/maven/RunMojo.java
b/tooling/maven/camel-maven-plugin/src/main/java/org/apache/camel/maven/RunMojo.java
index 5e62435..91d26ba 100644
---
a/tooling/maven/camel-maven-plugin/src/main/java/org/apache/camel/maven/RunMojo.java
+++
b/tooling/maven/camel-maven-plugin/src/main/java/org/apache/camel/maven/RunMojo.java
@@ -426,7 +426,7 @@ public class RunMojo extends AbstractExecMojo {
getLog().info("Starting Camel ...");
Method main =
Thread.currentThread().getContextClassLoader()
.loadClass(mainClass).getMethod("main",
String[].class);
- main.invoke(null, new Object[] { arguments });
+ main.invoke(null, arguments);
afterBootstrapCamel();
} catch (Exception e) { // just pass it on
