Skip to main content
Version: Next

Activemq

Activemq sink connector

Descriptionโ€‹

Used to write data to Activemq.

Key featuresโ€‹

Optionsโ€‹

nametyperequireddefault value
hoststringno-
portintno-
virtual_hoststringno-
usernamestringno-
passwordstringno-
queue_namestringyes-
uristringyes-
check_for_duplicatebooleanno-
client_idbooleanno-
copy_message_on_sendbooleanno-
disable_timeStamps_by_defaultbooleanno-
use_compressionbooleanno-
always_session_asyncbooleanno-
dispatch_asyncbooleanno-
nested_map_and_list_enabledbooleanno-
warnAboutUnstartedConnectionTimeoutbooleanno-
closeTimeoutintno-

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