This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from ec5d16cdbf79 chore(ci): use nats 2.15.0 instead of 2.15.1 for ppc64le
add 223ecca4442a CAMEL-25851: camel-paho-mqtt5 - consumers that share a
client each get the messages of their own topic (#28324)
No new revisions were added by this update.
Summary of changes:
.../paho/mqtt5/PahoMqtt5ClientCallback.java | 224 +++++++++++++++++++
.../component/paho/mqtt5/PahoMqtt5Consumer.java | 122 ++++++-----
.../mqtt5/PahoMqtt5ClientCallbackMatchesTest.java | 77 +++++++
.../mqtt5/PahoMqtt5SharedClientConsumersTest.java | 234 ++++++++++++++++++++
.../mqtt5/PahoMqtt5SharedClientReconnectTest.java | 65 ++++++
.../camel/component/paho/PahoClientCallback.java | 214 ++++++++++++++++++
.../apache/camel/component/paho/PahoConsumer.java | 102 +++++----
.../paho/PahoClientCallbackMatchesTest.java | 77 +++++++
.../paho/PahoSharedClientConsumersTest.java | 243 +++++++++++++++++++++
.../paho/PahoSharedClientReconnectTest.java | 66 ++++++
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 29 +++
11 files changed, 1347 insertions(+), 106 deletions(-)
create mode 100644
components/camel-paho-mqtt5/src/main/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ClientCallback.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ClientCallbackMatchesTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SharedClientConsumersTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SharedClientReconnectTest.java
create mode 100644
components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoClientCallback.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoClientCallbackMatchesTest.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoSharedClientConsumersTest.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoSharedClientReconnectTest.java
