You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2018/07/15 06:57:49 UTC
[camel] branch master updated: CAMEL-12650 Log messages that do not
match with their method function
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 <li...@outlook.com>
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);
}
}