Плагин Mule Amqp и Mel

Я хочу отправить сообщение для обмена с ключом маршрутизации. Сообщение, которое я хочу отправить, получено из полезной нагрузки, но ключ маршрутизации, который я устанавливаю в сообщении во входящих свойствах, а затем я устанавливаю: routingKey="#[message.inboundProperties.routingKey]", но он не работает

<flow name="ExportToFk" doc:name="ExportToFk">
        <vm:inbound-endpoint exchange-pattern="one-way" path="rabbitSenderVM" doc:name="SendToRabbit"/>
        <scripting:component doc:name="Groovy">
            <scripting:script engine="Groovy"><![CDATA[import org.mule.api.transport.PropertyScope

def xml = payload.xml
def routingKey = payload.routing

println "XML: $xml"
println "ROUTINGKEY: $routingKey"

message.setProperty('routingKey', routingKey, PropertyScope.INBOUND)

return xml]]></scripting:script>
        </scripting:component>
        <amqp:outbound-endpoint exchangeName="${amqp.exchange}" routingKey="#[message.inboundProperties.routingKey]" responseTimeout="10000" connector-ref="AMQP_Connector" doc:name="AMQP"/>
    </flow>

person lukisp    schedule 09.07.2013    source источник


Ответы (1)


Это известная проблема, которая в настоящее время находится в стадии разработки: https://github.com/mulesoft/mule-transport-amqp/issues/24

person David Dossot    schedule 09.07.2013