⭐️
Activemq
Activemq sink connector
Description
Used to write data to Activemq.
Key features
Options
| name | type | required | default value |
|---|---|---|---|
| host | string | no | - |
| port | int | no | - |
| virtual_host | string | no | - |
| username | string | no | - |
| password | string | no | - |
| queue_name | string | yes | - |
| uri | string | yes | - |
| check_for_duplicate | boolean | no | - |
| client_id | boolean | no | - |
| copy_message_on_send | boolean | no | - |
| disable_timeStamps_by_default | boolean | no | - |
| use_compression | boolean | no | - |
| always_session_async | boolean | no | - |
| dispatch_async | boolean | no | - |
| nested_map_and_list_enabled | boolean | no | - |
| warnAboutUnstartedConnectionTimeout | boolean | no | - |
| closeTimeout | int | no | - |
host [string]
the default host to use for connections
port [int]
the default port to use for connections
username [string]
the AMQP user name to use when connecting to the broker
password [string]
the password to use when connecting to the broker
uri [string]
convenience method for setting the fields in an AMQP URI: host, port, username, password and virtual host
queue_name [string]
the queue to write the message to
check_for_duplicate [boolean]
will check for duplucate messages
client_id [string]
client id
copy_message_on_send [boolean]
if true, enables new JMS Message object as part of the send method
disable_timeStamps_by_default [boolean]
disables timestamp for slight performance boost
use_compression [boolean]
Enables the use of compression on the message’s body.
always_session_async [boolean]
When true a separate thread is used for dispatching messages for each Session in the Connection.
always_sync_send [boolean]
When true a MessageProducer will always use Sync sends when sending a Message
close_timeout [boolean]
Sets the timeout, in milliseconds, before a close is considered complete.
dispatch_async [boolean]
Should the broker dispatch messages asynchronously to the consumer
nested_map_and_list_enabled [boolean]
Controls whether Structured Message Properties and MapMessages are supported
warn_about_unstarted_connection_timeout [int]
The timeout, in milliseconds, from the time of connection creation to when a warning is generated
Example
simple:
sink {
ActiveMQ {
uri="tcp://localhost:61616"
username = "admin"
password = "admin"
queue_name = "test1"
}
}
Changelog
Change Log
| Change | Commit | Version |
|---|---|---|
| [Improve][connector][activemq] Remove duplicate dependencies (#8753) | https://github.com/apache/seatunnel/commit/da6241aa1 | 2.3.10 |
| [improve] update activemq connector config option (#8580) | https://github.com/apache/seatunnel/commit/629f85b23 | 2.3.10 |
| [Improve][dist]add shade check rule (#8136) | https://github.com/apache/seatunnel/commit/51ef80001 | 2.3.9 |
| [Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786) | https://github.com/apache/seatunnel/commit/6b7c53d03 | 2.3.9 |
| Bump org.apache.activemq:activemq-client (#7323) | https://github.com/apache/seatunnel/commit/e23e3ac4e | 2.3.7 |
| [Feature][Activemq] Added activemq sink (#7251) | https://github.com/apache/seatunnel/commit/f0cefbeb4 | 2.3.7 |