This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 5a597b7 CAMEL-12650 Log messages that do not match with their method
function
5a597b7 is described below
commit 5a597b7bfe4aa0d3feb446953079697e0e642b4b
Author: zhenhaoli <[email protected]>
AuthorDate: Fri Jul 13 11:35:48 2018 -0400
CAMEL-12650 Log messages that do not match with their method function
---
camel-core/src/main/java/org/apache/camel/impl/ConsumerCache.java | 2 +-
.../camel/component/atomix/client/value/AtomixValueConsumer.java | 2 +-
.../src/main/java/org/apache/camel/component/aws/mq/MQProducer.java | 2 +-
.../digitalocean/producer/DigitalOceanDropletsProducer.java | 2 +-
.../org/apache/camel/component/docker/producer/DockerProducer.java | 2 +-
.../java/org/apache/camel/component/file/remote/FtpsEndpoint.java | 2 +-
.../kubernetes/deployments/KubernetesDeploymentsProducer.java | 6 +++---
.../camel/component/netty4/handlers/ClientChannelHandler.java | 2 +-
.../java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java | 2 +-
.../camel/component/sip/listener/SipPresenceAgentListener.java | 2 +-
.../camel/component/wordpress/producer/WordpressUserProducer.java | 2 +-
.../apache/camel/catalog/nexus/ConnectorCatalogNexusRepository.java | 2 +-
12 files changed, 14 insertions(+), 14 deletions(-)
diff --git a/camel-core/src/main/java/org/apache/camel/impl/ConsumerCache.java
b/camel-core/src/main/java/org/apache/camel/impl/ConsumerCache.java
index 7864bf9..a523a09 100644
--- a/camel-core/src/main/java/org/apache/camel/impl/ConsumerCache.java
+++ b/camel-core/src/main/java/org/apache/camel/impl/ConsumerCache.java
@@ -177,7 +177,7 @@ public class ConsumerCache extends ServiceSupport {
throw new FailedToCreateConsumerException(endpoint, e);
}
if (pooled && answer instanceof ServicePoolAware) {
- LOG.debug("Adding to producer service pool with key: {} for
producer: {}", endpoint, answer);
+ LOG.debug("Adding to consumer service pool with key: {} for
consumer: {}", endpoint, answer);
answer = pool.addAndAcquire(endpoint, answer);
} else {
boolean singleton = false;
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/value/AtomixValueConsumer.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/value/AtomixValueConsumer.java
index ecb759e..5c067bf 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/value/AtomixValueConsumer.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/value/AtomixValueConsumer.java
@@ -56,7 +56,7 @@ final class AtomixValueConsumer extends
AbstractAtomixClientConsumer<AtomixValue
.join();
- LOGGER.debug("Subscribe to events for queue: {}", resourceName);
+ LOGGER.debug("Subscribe to events for value: {}", resourceName);
this.listeners.add(this.value.onChange(this::onEvent).join());
}
diff --git
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQProducer.java
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQProducer.java
index 0151770..c217c14 100644
---
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQProducer.java
+++
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQProducer.java
@@ -177,7 +177,7 @@ public class MQProducer extends DefaultProducer {
try {
result = mqClient.rebootBroker(request);
} catch (AmazonServiceException ase) {
- LOG.trace("Delete Broker command returned the error code {}",
ase.getErrorCode());
+ LOG.trace("Reboot Broker command returned the error code {}",
ase.getErrorCode());
throw ase;
}
Message message = getMessageForResponse(exchange);
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 3c51fea..5550726 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
@@ -330,7 +330,7 @@ public class DigitalOceanDropletsProducer extends
DigitalOceanProducer {
}
Action action =
getEndpoint().getDigitalOceanClient().changeDropletKernel(dropletId,
exchange.getIn().getHeader(DigitalOceanHeaders.KERNEL_ID, Integer.class));
- LOG.trace("Rename Droplet {} : [{}] ", dropletId, action);
+ LOG.trace("Change Droplet {} : [{}] ", dropletId, action);
exchange.getOut().setBody(action);
}
diff --git
a/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java
b/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java
index e76cee0..097f4be 100644
---
a/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java
+++
b/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java
@@ -1019,7 +1019,7 @@ public class DockerProducer extends DefaultProducer {
*/
private StopContainerCmd executeStopContainerRequest(DockerClient client,
Message message) {
- LOGGER.debug("Executing Docker Kill Container Request");
+ LOGGER.debug("Executing Docker Stop Container Request");
String containerId =
DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration,
message, String.class);
diff --git
a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsEndpoint.java
b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsEndpoint.java
index 144be58..8200e45 100644
---
a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsEndpoint.java
+++
b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsEndpoint.java
@@ -197,7 +197,7 @@ public class FtpsEndpoint extends FtpEndpoint<FTPFile> {
}
if (log.isDebugEnabled()) {
- log.debug("Created FTPClient [connectTimeout: {}, soTimeout: {},
dataTimeout: {}, bufferSize: {}"
+ log.debug("Created FTPSClient [connectTimeout: {}, soTimeout: {},
dataTimeout: {}, bufferSize: {}"
+ ", receiveDataSocketBufferSize: {},
sendDataSocketBufferSize: {}]: {}",
new Object[]{client.getConnectTimeout(), getSoTimeout(),
dataTimeout, client.getBufferSize(),
client.getReceiveDataSocketBufferSize(),
client.getSendDataSocketBufferSize(), client});
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
index 84bb513..28f406f 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
@@ -149,11 +149,11 @@ public class KubernetesDeploymentsProducer extends
DefaultProducer {
DeploymentSpec deSpec =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_DEPLOYMENT_SPEC,
DeploymentSpec.class);
if (ObjectHelper.isEmpty(deploymentName)) {
LOG.error("Create a specific Deployment require specify a
Deployment name");
- throw new IllegalArgumentException("Create a specific pod require
specify a pod name");
+ throw new IllegalArgumentException("Create a specific Deployment
require specify a pod name");
}
if (ObjectHelper.isEmpty(namespaceName)) {
- LOG.error("Create a specific pod require specify a namespace
name");
- throw new IllegalArgumentException("Create a specific pod require
specify a namespace name");
+ LOG.error("Create a specific Deployment require specify a
namespace name");
+ throw new IllegalArgumentException("Create a specific Deployment
require specify a namespace name");
}
if (ObjectHelper.isEmpty(deSpec)) {
LOG.error("Create a specific Deployment require specify a
Deployment spec bean");
diff --git
a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
index 77f498e..f81fc1c 100644
---
a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
+++
b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
@@ -126,7 +126,7 @@ public class ClientChannelHandler extends
SimpleChannelInboundHandler<Object> {
// and could not return a response. We should count down to
stop waiting for a response
String address = configuration.getAddress();
if (LOG.isDebugEnabled()) {
- LOG.debug("Channel closed but no message received from
address: {}", address);
+ LOG.debug("Channel is inactive but no message received
from address: {}", address);
}
// don't fail the exchange if we actually specify to disconnect
if (!configuration.isDisconnect()) {
diff --git
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java
index a28729a..024daf6 100644
---
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java
+++
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQProducer.java
@@ -352,7 +352,7 @@ public class RabbitMQProducer extends DefaultAsyncProducer {
try {
if (replyManager != null) {
if (log.isDebugEnabled()) {
- log.debug("Stopping JmsReplyManager: {} from processing
replies from: {}", replyManager,
+ log.debug("Stopping RabbitMQReplyManager: {} from
processing replies from: {}", replyManager,
getEndpoint().getReplyTo() != null ?
getEndpoint().getReplyTo() : "temporary queue");
}
ServiceHelper.stopService(replyManager);
diff --git
a/components/camel-sip/src/main/java/org/apache/camel/component/sip/listener/SipPresenceAgentListener.java
b/components/camel-sip/src/main/java/org/apache/camel/component/sip/listener/SipPresenceAgentListener.java
index 75a5464..22648f2 100644
---
a/components/camel-sip/src/main/java/org/apache/camel/component/sip/listener/SipPresenceAgentListener.java
+++
b/components/camel-sip/src/main/java/org/apache/camel/component/sip/listener/SipPresenceAgentListener.java
@@ -189,7 +189,7 @@ public class SipPresenceAgentListener implements
SipListener, SipMessageCodes {
public void processTimeout(javax.sip.TimeoutEvent timeoutEvent) {
if (LOG.isWarnEnabled()) {
- LOG.warn("TimeoutEvent received at Sip Subscription Listener");
+ LOG.warn("TimeoutEvent received at Sip Presence Agent Listener");
}
}
diff --git
a/components/camel-wordpress/src/main/java/org/apache/camel/component/wordpress/producer/WordpressUserProducer.java
b/components/camel-wordpress/src/main/java/org/apache/camel/component/wordpress/producer/WordpressUserProducer.java
index b6426ed..7c7f9f9 100644
---
a/components/camel-wordpress/src/main/java/org/apache/camel/component/wordpress/producer/WordpressUserProducer.java
+++
b/components/camel-wordpress/src/main/java/org/apache/camel/component/wordpress/producer/WordpressUserProducer.java
@@ -37,7 +37,7 @@ public class WordpressUserProducer extends
AbstractWordpressProducer<User> {
}
protected User processUpdate(Exchange exchange) {
- LOG.debug("Trying to update the post {} with id {}",
exchange.getIn().getBody(), this.getConfiguration().getId());
+ LOG.debug("Trying to update the user {} with id {}",
exchange.getIn().getBody(), this.getConfiguration().getId());
return serviceUsers.update(getConfiguration().getId(),
exchange.getIn().getBody(User.class));
}
diff --git
a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ConnectorCatalogNexusRepository.java
b/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ConnectorCatalogNexusRepository.java
index 5cf1e03..98630d4 100644
---
a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ConnectorCatalogNexusRepository.java
+++
b/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ConnectorCatalogNexusRepository.java
@@ -125,7 +125,7 @@ public class ConnectorCatalogNexusRepository extends
BaseNexusRepository {
addConnector(dto, name, scheme, javaType, description,
csb.toString(), json[0], json[1], json[2]);
}
} catch (IOException e) {
- logger.warn("Error scanning JAR for custom Camel components", e);
+ logger.warn("Error scanning JAR for custom Camel connectors", e);
}
}
