消息总线#
此任务在MessageBus通信层上执行。它可以发布消息、发送消息并请求回复以及订阅特定主题。
输入#
| 名称 | 数据类型 | 是否是触发器 | 描述 |
|---|---|---|---|
| 激活 | boolean | 是 | 激活任何类型的操作 |
输出#
| 名称 | 数据类型 | 描述 |
|---|---|---|
| 成功 | Boolean | true 成功执行操作时发出的True值 |
| 错误 | Error | 处理此任务时发生的错误或SendRequest等待回复时发生的超时 |
不同的输入/输出#
根据在选项中选定的type,此任务可以具有不同的输入/输出。
操作类型 Publish#
输入#
| 名称 | 数据类型 | 是否是触发器 | 描述 |
|---|---|---|---|
| 主题 | String | 否 | 要发布的消息的主题 |
| message | any | 是 | 要发布的消息 |
操作类型 SendRequest#
输入#
| 名称 | 数据类型 | 是否是触发器 | 描述 |
|---|---|---|---|
| 主题 | String | 否 | 要发送的消息的主题 |
| message | any | 是 | 要发送的消息 |
输出#
| 名称 | 数据类型 | 描述 |
|---|---|---|
| 数据 | Object | SendRequest接收到回复消息时发出 |
操作类型 Subscribe#
输入#
| 名称 | 数据类型 | 是否是触发器 | 描述 |
|---|---|---|---|
| 主题 | String | 是 | 要侦听的主题。当接收到不同的主题时,将执行新的订阅 |
| 回复 | Object | 否 | 用于回复以下项的消息输入 SendRequest |
输出#
| 名称 | 数据类型 | 描述 |
|---|---|---|
| subscribedSubject | String | 输出从Publish/接收到的主题SendRequest |
| 数据 | Object | 从Publish/SendRequest接收到消息时发出 |
设置#
| 名称 | 数据类型 | PossibleValue | 默认 | 描述 |
|---|---|---|---|---|
| 操作 | Enum | PublishSendRequestSubscribe | Publish | 任务要执行的操作类型。 |
| 主题 | String | 要发布或订阅的消息的主题 | ||
| 超时 | Integer | 60000 | 等待回复消息的毫秒数。不适用于操作类型 Publish | |
| 自动激活 | Boolean | true | 对于操作类型Subscribe,如果将此标志设置为true,任务将自动订阅 subject |
行为#
此任务有三种不同的操作模式。
发布#
当在activate输入中接收到message或true值时,将激活此模式。
激活后,message将被发布到给定的主题(即发即弃),并且success输出将发出相应的值。
SendRequest#
当在activate输入中接收到message或true值时,将激活此模式。
激活后,将发送一条包含回复请求的message。
如果在设置中定义的时间间隔内收到回复消息,data和success输出都会发出相应的值。否则,如果在该时间间隔内未收到回复消息,将发生超时,并且error输出将发出错误。
订阅#
Subscribe操作由以下任一条件激活:
Auto Activate设置设为trueactivate输入具有true布尔值(或兼容值,例如1、true、t、yes、y)subject输入内容与已订阅的主题不同
激活后,当向订阅的主题发布消息时,data、subscribedSubject和success输出将发出相应的值。
如果activate输入接收到false布尔值并且已存在活动订阅,该订阅将立即被停用。
Note
当某个订阅接收到来自SendRequest的消息时,它将等待回复消息提供reply输入(等待时间在timeout设置中定义)。如果在该时间间隔内未接收到任何消息,则不会发送回复。
备注#
此任务使用基于上下文的数据的特定结构,称为zone。有关此主题的更多信息,请参阅区域页面。



