This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch con-mdc2
in repository https://gitbox.apache.org/repos/asf/camel.git
from 24ab9187237 CAMEL-22295: camel-core - Consumer can setup MDC with
route id during internal processing (for scheduled consumers)
add e2c2df11895 CAMEL-22295: camel-core - Consumer can setup MDC with
route id during internal processing
add a626e51d28f CAMEL-22295: camel-core - Consumer can setup MDC with
route id during internal processing
add 4355170fe0e CAMEL-22295: camel-core - Consumer can setup MDC with
route id during internal processing
add 3748625abdc CAMEL-22295: camel-core - Consumer can setup MDC with
route id during internal processing
add f1e396d341e CAMEL-22295: camel-core - Consumer can setup MDC with
route id during internal processing
No new revisions were added by this update.
Summary of changes:
.../aws2/kinesis/KclKinesis2Consumer.java | 2 +-
.../component/aws2/kinesis/Kinesis2Endpoint.java | 4 +-
.../camel/component/debezium/DebeziumConsumer.java | 2 +-
.../camel/component/debezium/DebeziumEndpoint.java | 4 +-
.../pubsublite/GooglePubsubLiteConsumer.java | 2 +-
.../pubsublite/GooglePubsubLiteEndpoint.java | 4 +-
.../google/pubsub/GooglePubsubConsumer.java | 2 +-
.../google/pubsub/GooglePubsubEndpoint.java | 4 +-
.../hazelcast/queue/HazelcastQueueConsumer.java | 2 +-
.../hazelcast/queue/HazelcastQueueEndpoint.java | 4 +-
.../smn/SimpleNotificationEndpoint.java | 6 ---
.../apache/camel/component/jms/JmsProducer.java | 4 +-
.../camel/component/kafka/KafkaConsumer.java | 2 +-
.../camel/component/kafka/KafkaEndpoint.java | 8 +--
.../camel/component/kafka/KafkaProducer.java | 2 +-
.../kubernetes/AbstractKubernetesEndpoint.java | 4 +-
.../config_maps/KubernetesConfigMapsConsumer.java | 2 +-
.../KubernetesCustomResourcesConsumer.java | 2 +-
.../deployments/KubernetesDeploymentsConsumer.java | 2 +-
.../events/KubernetesEventsConsumer.java | 2 +-
.../kubernetes/hpa/KubernetesHPAConsumer.java | 2 +-
.../namespaces/KubernetesNamespacesConsumer.java | 2 +-
.../kubernetes/nodes/KubernetesNodesConsumer.java | 2 +-
.../kubernetes/pods/KubernetesPodsConsumer.java | 2 +-
.../KubernetesReplicationControllersConsumer.java | 2 +-
.../services/KubernetesServicesConsumer.java | 2 +-
.../OpenshiftDeploymentConfigsConsumer.java | 2 +-
.../apache/camel/component/nats/NatsConsumer.java | 2 +-
.../apache/camel/component/nats/NatsEndpoint.java | 4 +-
...TelemetryInstrumentedThreadFactoryListener.java | 2 +-
.../camel/component/pgevent/PgEventConsumer.java | 2 +-
.../camel/component/pgevent/PgEventEndpoint.java | 4 +-
.../camel/component/rocketmq/RocketMQProducer.java | 2 +-
.../apache/camel/component/sjms/SjmsProducer.java | 4 +-
.../apache/camel/spi/ExecutorServiceManager.java | 3 +-
.../impl/engine/BaseExecutorServiceManager.java | 19 ++++---
.../impl/engine/MDCThreadFactoryListener.java | 63 ++++++++++++++++++++++
.../impl/DefaultExecutorServiceManagerTest.java | 4 +-
.../MDCRouteIdAwareTest.java} | 39 ++++++++------
.../camel/support/ScheduledPollConsumer.java | 14 -----
.../ROOT/pages/camel-4x-upgrade-guide-4_14.adoc | 3 ++
41 files changed, 152 insertions(+), 91 deletions(-)
create mode 100644
core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/MDCThreadFactoryListener.java
copy
core/camel-core/src/test/java/org/apache/camel/{component/file/FileProducerNoForcedWritesTest.java
=> processor/MDCRouteIdAwareTest.java} (63%)