0

我在WSO2 ESB中很新,我有以下问题。

在我的ESB流程中,我有一个将 XML 文档放入WSO2 MB队列的存储中介,这是我的消息存储的配置:

<?xml version="1.0" encoding="UTF-8"?>
<messageStore class="org.apache.synapse.message.store.impl.jms.JmsStore" name="glisMessageStore" xmlns="http://ws.apache.org/ns/synapse">
    <parameter name="store.jms.destination">glisQueue</parameter>
    <parameter name="store.producer.guaranteed.delivery.enable">false</parameter>
    <parameter name="store.jms.cache.connection">true</parameter>
    <parameter name="java.naming.factory.initial">org.wso2.andes.jndi.PropertiesFileInitialContextFactory</parameter>
    <parameter name="connectionfactory.QueueConnectionFactory">amqp://admin:admin@clientID/carbon?brokerlist='tcp://localhost:5675'</parameter>
    <parameter name="store.jms.JMSSpecVersion">1.1</parameter>
</messageStore>

如您所见,我的文档已放入glisQueue队列中。

然后我(在这个项目中)部署了一个名为glisMessageProcessor的消息处理器,它检查队列是否不为空,以及它是否包含一些它发送到的 XML 文档以及执行 Http 调用的外部 Web 服务,这是我的消息处理器的配置:

<?xml version="1.0" encoding="UTF-8"?>
<messageProcessor class="org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcessor" messageStore="glisMessageStore" name="glisMessageProcessor" targetEndpoint="glisEndpoint" xmlns="http://ws.apache.org/ns/synapse">
    <parameter name="client.retry.interval">1000</parameter>
    <parameter name="max.delivery.attempts">4</parameter>
    <parameter name="member.count">1</parameter>
    <parameter name="message.processor.reply.sequence">glisResponseSequence</parameter>
    <parameter name="max.delivery.drop">Disabled</parameter>
    <parameter name="interval">1000</parameter>
    <parameter name="is.active">true</parameter>
</messageProcessor>

如您所见,它使用glisMessageStore作为数据源(因此它使用其中的glisQueue队列定义来获取要发送的数据)并将这些数据发送到我的 Web 服务的端点glisEndpoint(它在我的项目)。

它工作正常,数据正确发送到由glisEndpoint表示的外部 Web 服务。

我唯一的问题是:我的网络服务在被调用时返回一条消息(包含一些我需要以某种方式存储的信息)。

我可以以某种方式配置我的glissMessageProcessor以检索这些响应消息并将其放入日志文件中吗?

4

1 回答 1

1

您只需要在名为“glisResponseSequence”的序列中使用日志调解器:这是您使用“message.processor.reply.sequence”参数定义的,这是响应的位置。

于 2017-05-18T07:09:13.517 回答