跳到主要内容
版本:2.3.8

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