Activemq

Activemq sink connector

Description​

Used to write data to Activemq.

Key features​

• exactly-once

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"
      }
}