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