2013-07-09 4 views
0

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

<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> 

ответ