This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 7e715b039f [Fix][Connector-V2] Close the Iceberg table loader even
when the record writer fails (#12326)
add c6ddef67e4 [Feature][Connector-V2] Add checkpoint-aware ActiveMQ queue
source (#12341)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/changelog/connector-activemq.md | 1 +
docs/en/connectors/sink/Activemq.md | 5 +-
docs/en/connectors/source/Activemq.md | 129 +++++
docs/zh/connectors/changelog/connector-activemq.md | 7 +
docs/zh/connectors/sink/Activemq.md | 5 +-
docs/zh/connectors/source/Activemq.md | 129 +++++
plugin-mapping.properties | 1 +
.../activemq/config/ActivemqSourceOptions.java | 51 ++
.../seatunnel/activemq/source/ActivemqSource.java | 98 ++++
.../activemq/source/ActivemqSourceEnumerator.java | 137 +++++
.../activemq/source/ActivemqSourceFactory.java | 131 +++++
.../activemq/source/ActivemqSourceReader.java | 366 ++++++++++++++
.../seatunnel/activemq/ActivemqFactoryTest.java | 97 ++++
.../activemq/source/ActivemqSourceReaderTest.java | 553 +++++++++++++++++++++
.../e2e/connector/activemq/ActivemqIT.java | 284 ++++++++++-
.../resources/activemq_source_to_console.conf} | 25 +-
16 files changed, 1990 insertions(+), 29 deletions(-)
create mode 100644 docs/en/connectors/source/Activemq.md
create mode 100644 docs/zh/connectors/source/Activemq.md
create mode 100644
seatunnel-connectors-v2/connector-activemq/src/main/java/org/apache/seatunnel/connectors/seatunnel/activemq/config/ActivemqSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-activemq/src/main/java/org/apache/seatunnel/connectors/seatunnel/activemq/source/ActivemqSource.java
create mode 100644
seatunnel-connectors-v2/connector-activemq/src/main/java/org/apache/seatunnel/connectors/seatunnel/activemq/source/ActivemqSourceEnumerator.java
create mode 100644
seatunnel-connectors-v2/connector-activemq/src/main/java/org/apache/seatunnel/connectors/seatunnel/activemq/source/ActivemqSourceFactory.java
create mode 100644
seatunnel-connectors-v2/connector-activemq/src/main/java/org/apache/seatunnel/connectors/seatunnel/activemq/source/ActivemqSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-activemq/src/test/java/org/apache/seatunnel/connectors/seatunnel/activemq/source/ActivemqSourceReaderTest.java
copy
seatunnel-e2e/{seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/pending_jobs_streaming.conf
=>
seatunnel-connector-v2-e2e/connector-activemq-e2e/src/test/resources/activemq_source_to_console.conf}
(68%)
