You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/10/26 10:40:06 UTC
[inlong] branch master updated (c6fd02418 -> 537f59962)

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from c6fd02418 [INLONG-6291][CVE] Update ini4j to fix the CVE-2022-41404 (#6292)
     add 537f59962 [INLONG-4986][Agent] Support MQTT Source (#6245)

No new revisions were added by this update.

Summary of changes:
 .../apache/inlong/agent/pojo/JobProfileDto.java    |  31 +++
 .../pojo/{DbCollectorTask.java => MqttJob.java}    |  46 ++--
 inlong-agent/agent-plugins/pom.xml                 |   5 +
 .../{SQLServerSource.java => MqttSource.java}      |  40 +--
 .../agent/plugin/sources/reader/MqttReader.java    | 238 ++++++++++++++++++
 .../agent/plugin/sources/TestMqttConnect.java      |  74 ++++++
 .../agent/plugin/sources/TestMqttReader.java       | 188 ++++++++++++++
 ...estSQLServerSource.java => TestMqttSource.java} |  20 +-
 .../apache/inlong/common/enums/TaskTypeEnum.java   |   4 +-
 licenses/inlong-agent/LICENSE                      |   1 +
 .../licenses/LICENSE-paho.mqtt.java.txt}           | 273 +--------------------
 pom.xml                                            |   1 +
 12 files changed, 603 insertions(+), 318 deletions(-)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/{DbCollectorTask.java => MqttJob.java} (51%)
 copy inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/{SQLServerSource.java => MqttSource.java} (61%)
 create mode 100644 inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java
 create mode 100644 inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestMqttConnect.java
 create mode 100644 inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestMqttReader.java
 copy inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/{TestSQLServerSource.java => TestMqttSource.java} (85%)
 copy licenses/{inlong-sort-connectors/licenses/LICENSE-connect-runtime.txt => inlong-agent/licenses/LICENSE-paho.mqtt.java.txt} (50%)