230.2.2. 查询参数(39 参数):


Expand
Name描述默认类型

BlockingExecutor (常见)

SSL 连接对内部线程池执行阻塞操作,除非您调用 setBlockingExecutor 方法来配置它们将改为使用的 executor。

 

executor

默认( 常见)

发送到 MQTT 代理的消息使用的默认保留策略

false

布尔值

cleanSession (通用)

如果您希望 MQTT 服务器在客户端会话之间保留主题订阅和黑名单,则设置为 false。默认值为 true。

false

布尔值

clientID ( 通用)

使用 设置会话中的客户端。这是一个 MQTT 服务器用来识别使用 setCleanSession (false); 的会话。id 必须为 23 个字符或更少。默认为自动生成的 id (基于套接字地址、端口和时间戳)。

 

字符串

connectAttemptsMax (common)

错误报告回客户端在第一次尝试连接到服务器前的最大重新连接尝试次数。设置为 -1 来使用无限尝试。默认值为 -1。

-1

long

connectWaitInSeconds (common)

组件将等待与 MQTT 代理建立连接的延迟(以秒为单位)

10

int

disconnectWaitInSeconds (common)

组件将在 MQTT 代理上的 stop ()上等待有效断开连接的秒数

5

int

dispatchQueue (common)

HawtDispatch 分配队列用于同步对连接的访问。如果没有通过 setDispatchQueue 方法配置显式队列,则会为连接创建新队列。如果您希望多个连接共享同一队列进行同步,则设置显式队列可能是方便的。

 

DispatchQueue

主机 (通用)

要连接的 MQTT 代理的 URI,这个组件也支持 SSL -g. ssl://127.0.0.1:8883

tcp://127.0.0.1:1883

URI

keepalive ( common)

以秒为单位配置 keep Alive 计时器。定义从客户端接收的消息之间的最大间隔时间。它使服务器能够检测到与客户端的网络连接是否已丢弃,而无需等待长的 TCP/IP 超时。

 

localAddress (通用)

要使用的本地 InetAddress 和端口

 

URI

maxReadRate (common)

设定此传输将接收数据每秒的最大字节数。此设置节流的读取,因此不会超过比率。默认为 0,它禁用节流。

 

int

maxWriteRate (common)

设置此传输将在以下位置发送数据的最大字节数。此设置节流写入,因此不会超过比率。默认为 0,它禁用节流。

 

int

mqttQosPropertyName (common)

在 Exchange 上查找独立发布的消息的属性名称。如果设置了此项( AtMostOnce 或 ExactlyOnce )-那么在发送到 MQTT 消息代理的消息中会设置 QoS。

MQTTQos

字符串

mqttRetainPropertyName (common)

在 Exchange 上查找独立发布的消息的属性名称。如果设置此项(选择布尔值)- 则保留的属性将针对发送到 MQTT 消息代理的消息上设置。

MQTTRetain

字符串

mqttTopicPropertyName (common)

这些在 Exchange 中查找的属性 - 以发布至

MQTTTopicPropertyName

字符串

publishTopicName (common)

发布消息的默认主题

camel/mqtt/test

字符串

qualityOfService (common)

用于主题的服务级别质量。

AtLeastOnce

字符串

receiveBufferSize (common)

设置内部套接字接收缓冲区的大小。默认值为 65536 (64k)

65536

int

reconnectAttemptsMax (common)

在服务器连接之前向客户端报告错误前的最大重新连接尝试次数。设置为 -1 来使用无限尝试。默认值为 -1。

-1

long

reconnectBackOffMultiplier (通用)

在重新连接尝试之间使用 Exponential backoff。设置为 1 可禁用 exponential backoff。默认值为 2。

2.0

double

ReconnectDelay (common)

在第一次重新连接尝试前等待 ms 中的多长时间。默认值为 10。

10

long

reconnectDelayMax (common)

重新尝试之间要等待的最大时间量(以 ms 为单位)。默认值为 30,000。

30000

long

sendBufferSize (common)

设置内部套接字发送缓冲区的大小。默认值为 65536 (64k)

65536

int

sendWaitInSeconds (common)

组件在引发异常前等待来自 MQTT 代理收到确认已发布的消息的最长时间。

5

int

SSLContext (常见)

使用 SSLContext 配置配置安全性

 

SSLContext

subscribeTopicName (common)

deprecated These 在 Endpoint - 中设置了从 MQTT 继承的属性

 

字符串

subscribeTopicNames (common)

要查找消息的以逗号分隔的主题列表。请注意,此列表中的每一项都可以包含 MQTT 通配符(和/或 #),以便订阅在层次结构中与特定模式匹配的主题。例如,是层次结构中层次结构中所有主题的通配符,因此如果代理主题为 topics/one 和 topics/two,则主题/可用于订阅这两者。这里需要考虑的注意事项是,如果代理添加了 topics/three,路由也将开始从该主题接收消息。

 

字符串

trafficClass (通用)

设置从传输发送的数据包的 IP 标头中的流量类或类型服务八位字节。默认为 8,这意味着流量应该针对吞吐量进行优化。

8

int

版本 (通用)

设置为 3.1.1,以使用 MQTT 版本 3.1.1.否则默认为 3.1 协议版本。

3.1

字符串

willMessage (通用)

要发送的消息。默认为零长度。

 

字符串

willQos (通用)

设置用于 Will 消息的服务质量。默认为 AT_MOST_ONCE。

AtMostOnce

QoS

willRetain (common)

如果您希望使用保留选项发布,则设置为 true。

 

QoS

IfTopic (common)

如果服务器设置了服务器,如果客户端有意外断开连接,则将向指定的主题发布消息。

 

字符串

bridgeErrorHandler (consumer)

允许将消费者桥接到 Camel 路由 Error Handler,这意味着使用者试图获取传入消息或类似信息时出现任何异常,现在将作为一个消息进行处理,并由路由 Error Handler 处理。默认情况下,使用者将使用 org.apache.camel.spi.Exception 处理程序处理异常,该处理程序将记录在 WARN 或 ERROR 级别,并忽略。

false

布尔值

exceptionHandler (消费者)

要让使用者使用自定义 ExceptionHandler。请注意,如果启用了选项 bridgeErrorHandler,则不使用这个选项。默认情况下,消费者处理异常,这将在 WARN 或 ERROR 级别记录,并忽略。

 

ExceptionHandler

exchangePattern (consumer)

在使用者创建交换时设置交换模式。

 

ExchangePattern

lazySessionCreation (复制器)

如果远程服务器启动时没有启动并运行,则会话可能会延迟以避免异常。

true

布尔值

同步 (高级)

设置同步处理是否应当严格使用,还是允许 Camel 使用异步处理(如果受支持)。

false

布尔值

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat