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โ
next versionโ
- Add Activemq Source Connector