问题描述
我们正在从 Mule 3 迁移到 Mule 4,在我们的一项功能中,我们需要将消息发布到一个主题,并且下游另一个 mule 组件正在从桥接到该主题的队列中消费。
这里没什么特别的。
为了确保我们能够通过日志跟踪流,我们在向主题(Mule 3)发布消息时发送了“TrackingId”属性
message.setoutboundProperty("XYZ_TrackingID",flowVars['idFromUI']);
return payload;
但是,当我在 Mule 4 中尝试相同的操作时,我们得到以下异常:
ERROR 2020-12-20 10:09:12,214 [[MuleRuntime].cpuIntensive.14: [mycomponent].my_Flow.cpu_INTENSIVE
@66024695] org.mule.runtime.core.internal.exception.OnErrorPropagateHandler:
Message : groovy.lang.MissingMethodException: No signature of method:
org.mule.runtime.api.el.BindingContextUtils$MessageWrapper.setoutboundproperty() is applicable for
argument types: (java.lang.String,org.mule.weave.v2.el.ByteArrayBasedCursorStream) values:
[XYZ_TrackingID,"1234567"].\nError type : (set debug level logging or '-
Dmule.verbose.exceptions=true' for
everything)\n********************************************************************************
检查互联网,似乎在 Mule4 中设置出站属性已根据 here
删除那么我如何在 Mule 4 中实现相同的目标?
解决方法
出于多种原因,甚至不要尝试这样做。因为一种消息结构是不同的,所以输出属性不再存在,该方法甚至不存在。另一方面,在 Mule 4 组件中,如 Groovy 组件只能返回一个值而不能更改事件。他们无法决定将分配给什么值。您可以在配置中设置目标(有效负载或变量)而不更改属性。请注意,Mule 4 中的变量由 var.
引用,而不是像 Mule 3(即 flowVars.
)中那样由 vars.idFromUI
引用。
有一种更简单的方法可以在 Mule 4 JMS 连接器中设置消息属性。使用 properties 元素并将其传递给具有属性的对象。
例如它可能是这样的:
<jms:publish config-ref="JMS_config" destination="${bridgeDestination}" destinationType="TOPIC">
<jms:message>
<jms:body>#["bridged_" ++ payload]</jms:body>
<jms:properties>#[{
XYZ_TrackingID: vars.idFromUI
}]</jms:properties>
</jms:message>
</jms:publish>
它在文档中:https://docs.mulesoft.com/jms-connector/1.0/jms-publish#setting-user-properties。我从那里改编了我的例子。
,我不确定 Correlation Id
是否用于您的场景的跟踪 ID。但是你可以传递一个 CID,如下所示。它在 mule 文档中。
https://docs.mulesoft.com/jms-connector/1.7/jms-publish
<jms:publish config-ref="JMS_config" sendCorrelationId="ALWAYS" destination="#[attributes.headers.replyTo.destination]">
<jms:message correlationId="#[attributes.headers.correlationId]"/>
</jms:publish>
如果您的首要任务是自定义要发布的跟踪 ID,请尝试传递以下格式。键名可能因您的用例而异。
<jms:publish config-ref="JMS_config" destination="${bridgeDestination}" destinationType="TOPIC">
<jms:message>
<jms:body>#["bridged_" ++ payload]</jms:body>
<jms:properties>#[{
AUTH_TYPE: 'jwt',AUTH_TOKEN: attributes.queryParams.token
}]</jms:properties>
</jms:message>
</jms:publish>
在上面的表达式 attributes.queryParams.token
基本上是试图访问 token
查询参数,该参数作为属性 AUTH_TOKEN
key-name 传递给 JMS,由 API 通过 HTTP 使用侦听器或请求者更早。
但是,attributes.headers.correlationId
是一个标题。 queryParams 和 headers 都是 Mule 4 中属性的一部分。