跳转至

消息总线#

image23

此任务在MessageBus通信层上执行。它可以发布消息、发送消息并请求回复以及订阅特定主题。

输入#

名称 数据类型 是否是触发器 描述
激活 boolean 激活任何类型的操作

输出#

名称 数据类型 描述
成功 Boolean true 成功执行操作时发出的True值
错误 Error 处理此任务时发生的错误或SendRequest等待回复时发生的超时

不同的输入/输出#

根据在选项中选定的type,此任务可以具有不同的输入/输出。

操作类型 Publish#

1561732918756

输入#

名称 数据类型 是否是触发器 描述
主题 String 要发布的消息的主题
message any 要发布的消息

操作类型 SendRequest#

1561733291987

输入#

名称 数据类型 是否是触发器 描述
主题 String 要发送的消息的主题
message any 要发送的消息

输出#

名称 数据类型 描述
数据 Object SendRequest接收到回复消息时发出

操作类型 Subscribe#

1561733468540

输入#

名称 数据类型 是否是触发器 描述
主题 String 要侦听的主题。当接收到不同的主题时,将执行新的订阅
回复 Object 用于回复以下项的消息输入 SendRequest

输出#

名称 数据类型 描述
subscribedSubject String 输出从Publish/接收到的主题SendRequest
数据 Object 从Publish/SendRequest接收到消息时发出

设置#

名称 数据类型 PossibleValue 默认 描述
操作 Enum Publish
SendRequest
Subscribe
Publish 任务要执行的操作类型。
主题 String 要发布或订阅的消息的主题
超时 Integer 60000 等待回复消息的毫秒数。不适用于操作类型 Publish
自动激活 Boolean true 对于操作类型Subscribe,如果将此标志设置为true,任务将自动订阅 subject

1561733783455

行为#

此任务有三种不同的操作模式。

发布#

当在activate输入中接收到message或true值时,将激活此模式。

激活后,message将被发布到给定的主题(即发即弃),并且success输出将发出相应的值。

SendRequest#

当在activate输入中接收到message或true值时,将激活此模式。

激活后,将发送一条包含回复请求的message

如果在设置中定义的时间间隔内收到回复消息,datasuccess输出都会发出相应的值。否则,如果在该时间间隔内未收到回复消息,将发生超时,并且error输出将发出错误。

订阅#

Subscribe操作由以下任一条件激活:

  • Auto Activate设置设为 true
  • activate输入具有true布尔值(或兼容值,例如1truetyesy
  • subject输入内容与已订阅的主题不同

激活后,当向订阅的主题发布消息时,datasubscribedSubjectsuccess输出将发出相应的值。

如果activate输入接收到false布尔值并且已存在活动订阅,该订阅将立即被停用。

Note

当某个订阅接收到来自SendRequest的消息时,它将等待回复消息提供reply输入(等待时间在timeout设置中定义)。如果在该时间间隔内未接收到任何消息,则不会发送回复。

备注#

此任务使用基于上下文的数据的特定结构,称为zone。有关此主题的更多信息,请参阅区域页面。