import ChangeLog from ‘../changelog/connector-activemq.md’;

Activemq

Activemq 接收器连接器

描述

用于将数据写入 Activemq.

关键特性

• [ ] 精确一次

选项

名称	类型	必需	默认值
host	string	否	-
port	int	否	-
virtual_host	string	否	-
username	string	否	-
password	string	否	-
queue_name	string	是	-
uri	string	是	-
check_for_duplicate	boolean	否	-
client_id	boolean	否	-
copy_message_on_send	boolean	否	-
disable_timeStamps_by_default	boolean	否	-
use_compression	boolean	否	-
always_session_async	boolean	否	-
dispatch_async	boolean	否	-
nested_map_and_list_enabled	boolean	否	-
warnAboutUnstartedConnectionTimeout	boolean	否	-
closeTimeout	int	否	-

host [string]

用于连接的默认主机.

port [int]

用于连接的默认端口

username [string]

用于连接的默认端口

password [string]

连接到代理时使用的密码

uri [string]

用于设置 AMQP URI 中字段（主机、端口、用户名、密码和虚拟主机）的便捷方法

queue_name [string]

写入消息的队列

check_for_duplicate [boolean]

将检查重复消息

client_id [string]

客户端ID

copy_message_on_send [boolean]

如果为true，则启用新的JMS消息对象作为发送方法的一部分

disable_timeStamps_by_default [boolean]

禁用时间戳以获得轻微的性能提升.

use_compression [boolean]

允许对消息正文使用压缩.

always_session_async [boolean]

当为true时，将使用单独的线程为连接中的每个会话分派消息.

always_sync_send [boolean]

当为true时，MessageProducer在发送消息时将始终使用同步发送

close_timeout [boolean]

设置关闭完成前的超时时间（以毫秒为单位）.

dispatch_async [boolean]

代理是否应该异步地向消费者发送消息

nested_map_and_list_enabled [boolean]

控制是否支持结构化消息属性和MapMessages

warn_about_unstarted_connection_timeout [int]

从创建连接到生成警告的超时时间（毫秒）

示例

简单:

sink {
      ActiveMQ {
          uri="tcp://localhost:61616"
          username = "admin"
          password = "admin"
          queue_name = "test1"
      }
}

变更日志