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 2017/05/30 07:08:26 UTC
[2/2] camel git commit: fix CAMEL-11352
fix CAMEL-11352
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a1f953ba
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a1f953ba
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a1f953ba
Branch: refs/heads/camel-2.19.x
Commit: a1f953bab65a6ef9314033dd296a3e904d3a5c56
Parents: bcac1fb
Author: xldai <xl...@talend.com>
Authored: Tue May 30 14:56:47 2017 +0800
Committer: Claus Ibsen <da...@apache.org>
Committed: Tue May 30 09:08:17 2017 +0200
----------------------------------------------------------------------
.../camel/component/paxlogging/PaxLoggingConsumer.java | 13 ++-----------
1 file changed, 2 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/a1f953ba/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java b/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java
index 7cebd17..2144178 100644
--- a/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java
+++ b/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java
@@ -55,19 +55,10 @@ public class PaxLoggingConsumer extends DefaultConsumer implements PaxAppender {
public void doAppend(final PaxLoggingEvent paxLoggingEvent) {
// in order to "force" the copy of properties (especially the MDC ones) in the local thread
paxLoggingEvent.getProperties();
- executor.execute(new Runnable() {
- public void run() {
- sendExchange(paxLoggingEvent);
- }
- });
+ sendExchange(paxLoggingEvent);
}
- protected void sendExchange(PaxLoggingEvent paxLoggingEvent) {
- MDC.put(PaxLoggingConsumer.class.getName(), endpoint.getAppender());
- if (paxLoggingEvent.getProperties().containsKey(PaxLoggingConsumer.class.getName())) {
- return;
- }
-
+ protected void sendExchange(final PaxLoggingEvent paxLoggingEvent) {
Exchange exchange = endpoint.createExchange();
// TODO: populate exchange headers
exchange.getIn().setBody(paxLoggingEvent);