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 372d3cd7b4 [Test][E2E] Isolate the RocketMqIT sink topics and wait for
row visibility before reading (#12701)
add 83603e19b7 [Improve] [Connector-V2] Improve ActiveMQ sink: fix
resource leak and add config options (#12698)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/sink/Activemq.md | 11 +
docs/zh/connectors/sink/Activemq.md | 19 +-
.../seatunnel/activemq/client/ActivemqClient.java | 87 +++-
.../activemq/config/ActivemqSinkOptions.java | 77 ++++
.../activemq/sink/ActivemqSinkFactory.java | 20 +-
.../seatunnel/activemq/ActivemqFactoryTest.java | 9 +
.../activemq/client/ActivemqClientTest.java | 510 +++++++++++++++++++++
7 files changed, 720 insertions(+), 13 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-activemq/src/test/java/org/apache/seatunnel/connectors/seatunnel/activemq/client/ActivemqClientTest.java
