This is an automated email from the ASF dual-hosted git repository.
apupier pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 1ba71e2bee86 CAMEL-24783: camel-kafka - don't continue routing while
batch sends are still in flight (#27142)
new fabf0146f97d CAMEL-25030: camel-hivemq: add MQTT 3.1.1 protocol support
new 5eb52bd8e3a7 CAMEL-25030: camel-hivemq: document MQTT 3.1.1 support
and regenerate catalog
new 363d2ef35fb5 CAMEL-25030: camel-hivemq: add test coverage for MQTT
3.1.1 support
new 1f77f911259b CAMEL-25030: camel-hivemq: extract shared
reconnect-cancellation listener
new 68979efc222c CAMEL-25030: camel-hivemq: expand MQTT 3.1.1 test coverage
new ca7c6e1f0760 CAMEL-25030: camel-hivemq: document cleanStart semantics
differ by version
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/camel/catalog/components/hivemq.json | 44 +++---
.../camel/catalog/docs/hivemq-component.adoc | 24 +++-
.../hivemq/HiveMQComponentConfigurer.java | 6 +
.../component/hivemq/HiveMQEndpointConfigurer.java | 6 +
.../component/hivemq/HiveMQEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/hivemq/hivemq.json | 44 +++---
.../src/main/docs/hivemq-component.adoc | 24 +++-
.../component/hivemq/HiveMQClientAdapter.java | 63 +++++++++
.../component/hivemq/HiveMQConfiguration.java | 20 ++-
.../camel/component/hivemq/HiveMQConsumer.java | 39 +++---
.../camel/component/hivemq/HiveMQEndpoint.java | 104 ++------------
.../camel/component/hivemq/HiveMQMessage.java} | 15 +--
.../camel/component/hivemq/HiveMQProducer.java | 27 ++--
.../camel/component/hivemq/Mqtt3ClientAdapter.java | 136 +++++++++++++++++++
.../camel/component/hivemq/Mqtt5ClientAdapter.java | 136 +++++++++++++++++++
.../hivemq/MqttReconnectCancellation.java | 63 +++++++++
...adIT.java => AbstractHiveMQEmptyPayloadIT.java} | 9 +-
...cIT.java => AbstractHiveMQOverrideTopicIT.java} | 9 +-
...inIT.java => AbstractHiveMQQosAndRetainIT.java} | 10 +-
...micIT.java => AbstractHiveMQSendDynamicIT.java} | 19 ++-
.../component/hivemq/HiveMQClientAccessTest.java | 113 ++++++++++++++++
.../component/hivemq/HiveMQConfigurationTest.java | 4 +
.../component/hivemq/HiveMQEmptyPayloadIT.java | 54 +-------
.../component/hivemq/HiveMQEndpointAuthTest.java | 68 ++++++++--
.../hivemq/HiveMQEndpointConnectTest.java | 36 ++---
.../hivemq/HiveMQMqtt311EmptyPayloadIT.java | 10 +-
.../hivemq/HiveMQMqtt311OverrideTopicIT.java | 10 +-
...entPubSubIT.java => HiveMQMqtt311PubSubIT.java} | 16 +--
.../hivemq/HiveMQMqtt311QosAndRetainIT.java | 10 +-
.../hivemq/HiveMQMqtt311SendDynamicIT.java | 10 +-
.../component/hivemq/HiveMQOverrideTopicIT.java | 53 +-------
.../component/hivemq/HiveMQQosAndRetainIT.java | 74 +---------
.../component/hivemq/HiveMQSendDynamicIT.java | 51 +------
.../dsl/HivemqComponentBuilderFactory.java | 28 +++-
.../endpoint/dsl/HiveMQEndpointBuilderFactory.java | 150 +++++++++++++++++++--
35 files changed, 1002 insertions(+), 486 deletions(-)
create mode 100644
components/camel-hivemq/src/main/java/org/apache/camel/component/hivemq/HiveMQClientAdapter.java
copy
components/{camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiTool.java
=>
camel-hivemq/src/main/java/org/apache/camel/component/hivemq/HiveMQMessage.java}
(74%)
create mode 100644
components/camel-hivemq/src/main/java/org/apache/camel/component/hivemq/Mqtt3ClientAdapter.java
create mode 100644
components/camel-hivemq/src/main/java/org/apache/camel/component/hivemq/Mqtt5ClientAdapter.java
create mode 100644
components/camel-hivemq/src/main/java/org/apache/camel/component/hivemq/MqttReconnectCancellation.java
copy
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/{HiveMQEmptyPayloadIT.java
=> AbstractHiveMQEmptyPayloadIT.java} (87%)
copy
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/{HiveMQOverrideTopicIT.java
=> AbstractHiveMQOverrideTopicIT.java} (89%)
copy
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/{HiveMQQosAndRetainIT.java
=> AbstractHiveMQQosAndRetainIT.java} (92%)
copy
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/{HiveMQSendDynamicIT.java
=> AbstractHiveMQSendDynamicIT.java} (78%)
create mode 100644
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQClientAccessTest.java
copy
catalog/camel-route-parser/src/test/java/org/apache/camel/parser/java/MyPartialRoute.java
=>
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQMqtt311EmptyPayloadIT.java
(77%)
copy
catalog/camel-route-parser/src/test/java/org/apache/camel/parser/java/MyPartialRoute.java
=>
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQMqtt311OverrideTopicIT.java
(76%)
copy
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/{HiveMQComponentPubSubIT.java
=> HiveMQMqtt311PubSubIT.java} (80%)
copy
catalog/camel-route-parser/src/test/java/org/apache/camel/parser/java/MyPartialRoute.java
=>
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQMqtt311QosAndRetainIT.java
(77%)
copy
catalog/camel-route-parser/src/test/java/org/apache/camel/parser/java/MyPartialRoute.java
=>
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQMqtt311SendDynamicIT.java
(77%)
