You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2021/02/09 07:35:29 UTC
[camel] branch regen_bot updated (f93ed92 -> c71771c)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git.
from f93ed92 Polished
add 12b8e00 CAMEL-16094 camel-milo: connection caching. (#5054)
add d0082cb CAMEL-16094 camel-milo: connection caching.
add a366f69 CAMEL-16138: Allow KafkaClientFactory to be used without explicit broker URLs
add 7c5bf3b Regen
add c71771c CAMEL-16138: Allow KafkaClientFactory to be used without explicit broker URLs
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/kafka.json | 2 +-
.../camel/catalog/components/milo-client.json | 1 +
.../apache/camel/catalog/docs/kafka-component.adoc | 2 +-
.../camel/catalog/docs/milo-client-component.adoc | 3 +-
.../component/kafka/KafkaComponentConfigurer.java | 5 ++
.../org/apache/camel/component/kafka/kafka.json | 2 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 2 +-
.../component/kafka/DefaultKafkaClientFactory.java | 12 +++
.../camel/component/kafka/KafkaClientFactory.java | 10 +++
.../camel/component/kafka/KafkaComponent.java | 8 +-
.../camel/component/kafka/KafkaConsumer.java | 14 +---
.../camel/component/kafka/KafkaProducer.java | 7 +-
.../camel/component/kafka/KafkaConsumerTest.java | 6 +-
.../milo/client/MiloClientComponentConfigurer.java | 11 +++
.../camel/component/milo/client/milo-client.json | 1 +
.../src/main/docs/milo-client-component.adoc | 3 +-
.../client/MiloClientCachingConnectionManager.java | 95 ++++++++++++++++++++++
.../component/milo/client/MiloClientComponent.java | 13 ++-
.../milo/client/MiloClientConnection.java | 6 +-
.../milo/client/MiloClientConnectionManager.java} | 27 +++---
.../component/milo/client/MiloClientConsumer.java | 6 +-
.../component/milo/client/MiloClientEndpoint.java | 19 +++--
.../component/milo/client/MiloClientProducer.java | 10 +--
.../MiloClientCachingConnectionManagerTest.java | 72 ++++++++++++++++
.../dsl/KafkaComponentBuilderFactory.java | 4 +-
.../dsl/MiloClientComponentBuilderFactory.java | 17 ++++
.../modules/ROOT/pages/kafka-component.adoc | 2 +-
.../modules/ROOT/pages/milo-client-component.adoc | 3 +-
28 files changed, 292 insertions(+), 71 deletions(-)
create mode 100644 components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientCachingConnectionManager.java
copy components/{camel-digitalocean/src/main/java/org/apache/camel/component/digitalocean/constants/DigitalOceanResources.java => camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientConnectionManager.java} (68%)
create mode 100644 components/camel-milo/src/test/java/org/apache/camel/component/milo/MiloClientCachingConnectionManagerTest.java