WSO2-动态注入到端点的值

Question

我是WSO2 ESB的新手，我正在努力解决与动态生成的端点地址uris有关的一个问题。

我随后tutorial如何使用的RabbitMQ WSO2整合和我创建了以下端点：

<?xml version="1.0" encoding="UTF-8"?> 
    <endpoint xmlns="http://ws.apache.org/ns/synapse" name="Test2"> 
     <address trace="disable" uri="rabbitmq:/Test?rabbitmq.server.host.name=localhost&amp;rabbitmq.server.port=5672&amp;rabbitmq.server.user.name=test&amp;rabbitmq.server.password=test&amp;rabbitmq.queue.name=outputQueue_001&amp;rabbitmq.exchange.name=amq.direct&amp;rabbitmq.queue.routing.key=outputQueue_001&amp;rabbitmq.message.content.type=application/json" /> 
</endpoint> 

不过，我想动态地注入rabbitmq.server.host.name的价值，所以我创建了一个本地条目，如下图所示：

<?xml version="1.0" encoding="UTF-8"?> 
    <localEntry key="queue.hostname" xmlns="http://ws.apache.org/ns/synapse"><![CDATA[localhost]]></localEntry> 

并注入该值到端点：

<?xml version="1.0" encoding="UTF-8"?> 
<endpoint xmlns="http://ws.apache.org/ns/synapse" name="Test2"> 
    <property expression="get-property('queue.hostname')" name="queue.hostname" scope="default" type="STRING" /> 
    <address trace="disable" uri="rabbitmq:/Test?rabbitmq.server.host.name={queue.hostname}&amp;rabbitmq.server.port=5672&amp;rabbitmq.server.user.name=test&amp;rabbitmq.server.password=test&amp;rabbitmq.queue.name=outputQueue_001&amp;rabbitmq.exchange.name=amq.direct&amp;rabbitmq.queue.routing.key=outputQueue_001&amp;rabbitmq.message.content.type=application/json" /> 
</endpoint> 

在测试过程中，我发现在不正确地注入到URI和URI该属性queue.hostname值：

rabbitmq:/Test?rabbitmq.server.host.name={queue.hostname}&rabbitmq.server.port=5672&rabbitmq.server.user.name=test&rabbitmq.server.password=test&rabbitmq.queue.name=outputQueue_001&rabbitmq.exchange.name=amq.direct&rabbitmq.queue.routing.key=outputQueue_001&rabbitmq.message.content.type=application/json 

代替：

rabbitmq:/Test?rabbitmq.server.host.name=localhost&rabbitmq.server.port=5672&rabbitmq.server.user.name=test&rabbitmq.server.password=test&rabbitmq.queue.name=outputQueue_001&rabbitmq.exchange.name=amq.direct&rabbitmq.queue.routing.key=outputQueue_001&rabbitmq.message.content.type=application/json 

你知道我在做什么错误？ 我会补充任何示例代码。

预先感谢您！

Answer 1

当你从物业中介采取的价值观，它不能在URI的中间分配为它并不需要的参数值。所以你必须为此使用端点模板。

示例场景：根据您的情况

<template xmlns="http://ws.apache.org/ns/synapse" name="TM_out_endpoint_template"> 
    <axis2ns158:parameter xmlns:axis2ns158="http://ws.apache.org/ns/synapse" name="host">  </axis2ns158:parameter> 
<endpoint name="$name"> 
    <address uri="jms:/MyQueue?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://$host:61616&transport.jms.DestinationType=queue"> 
    <suspendOnFailure> 
     <progressionFactor>1.0</progressionFactor> 
    </suspendOnFailure> 
    <markForSuspension> 
     <retriesBeforeSuspension>0</retriesBeforeSuspension> 
     <retryDelay>0</retryDelay> 
    </markForSuspension> 
    </address> 
    </endpoint> 
</template> 

使用。参考：https://docs.wso2.com/display/ESB490/Endpoint+Template