简介
引擎用于描述消息在集成流中各个节点之间传递的数据结构。
坐标:com.alibaba.bwif.script.core.StepMessage。
结构说明
属性 | 类型 | 说明 |
id | String | 消息的唯一标识,每个节点的输入消息和输出消息ID都不同。 |
attribute | Map |
|
payload | Object |
|
variable | Map |
|
error | StepException | 保存错误信息。 |
构造方式
只能由集成流引擎构造,不支持在脚本中构造。
方法列表
方法 | 说明 |
String getTrackId() | 是流运行一次的标识,即在调试器中与运行日志的TraceID对应。 |
String getId() | 标识每个节点消息的唯一ID,每经过一个处理节点ID会变化。 |
Object getPayload() | 获取Payload。返回对象为 Object 需要自己转换,例如:HttpRequest request= message.getPayload()。 |
Map getVariable() | 变量为Map类型。 |
Map getAttribute() | 节点的配置属性,记录节点的配置信息,连接器节点连接器的配置参数在这里体现。 |
StepException getError() | 错误信息为上一个节点向下传递,参见 com.alibaba.bwif.script.core.StepException。 |