0

我使用of插入了一些json内容：queueWSO2 Message BrokerAPIWSO2 ESB

<?xml version="1.0" encoding="UTF-8"?>
<inSequence xmlns="http://ws.apache.org/ns/synapse">
    <property name="Accept" scope="transport" type="STRING" value="application/json"/>
    <call>
        <endpoint>
            <http method="GET" uri-template="http://localhost:9769/services/orderApi/orders"/>
        </endpoint>
    </call>
    <iterate continueParent="true" expression="//orders/order">
        <target sequence="insertOrdersMQ"/>
    </iterate>
    <respond/>
</inSequence>

在此API，我迭代了 的json响应endpoint并使用以下命令将订单插入到一个Message Broker's queue中sequence：

<?xml version="1.0" encoding="UTF-8"?>
<sequence name="insertOrdersMQ" xmlns="http://ws.apache.org/ns/synapse">
    <log level="custom">
        <property name="Log: " value="Inserting order on queue"/>
    </log>
    <property name="OUT_ONLY" value="true"/>
    <property name="FORCE_SC_ACCEPTED" scope="axis2" value="true"/>
    <send>
        <endpoint>
            <address uri="jms:/orders_mb?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&amp;java.naming.factory.initial=org.wso2.andes.jndi.PropertiesFileInitialContextFactory&amp;java.naming.provider.url=repository/conf/jndi.properties&amp;transport.jms.DestinationType=queue"/>
        </endpoint>
    </send>
</sequence>

然后，我创建了一个Message Processorat WSO2 ESB，因为我想在 orders_mb 上使用这些消息，queue然后在另一个中使用sequence。这是Message Storeand的代码Message Processor：

<messageStore name="orders_Store" class="org.apache.synapse.message.store.impl.jms.JmsStore" xmlns="http://ws.apache.org/ns/synapse">
   <parameter name="java.naming.factory.initial">org.wso2.andes.jndi.PropertiesFileInitialContextFactory</parameter>
   <parameter name="java.naming.provider.url">repository/conf/jndi.properties</parameter>
   <parameter name="store.jms.destination">orders_mb</parameter>
   <parameter name="store.jms.JMSSpecVersion">1.1</parameter>
   <parameter name="store.producer.guaranteed.delivery.enable">false</parameter>
   <parameter name="store.failover.message.store.name">orders_mb</parameter>
</messageStore>


<messageProcessor name="ordersProcessor" class="org.apache.synapse.message.processor.impl.sampler.SamplingProcessor" messageStore="orders_Store" xmlns="http://ws.apache.org/ns/synapse">
   <parameter name="interval">1000</parameter>
   <parameter name="concurrency">1</parameter>
   <parameter name="sequence">insertOrdersDB</parameter>
   <parameter name="is.active">true</parameter>
</messageProcessor>

最后，这里是sequence发送Message Processor消息的queue：

<?xml version="1.0" encoding="UTF-8"?>
<sequence name="insertOrdersDB" xmlns="http://ws.apache.org/ns/synapse">
    <log level="full">
        <property name="Log: " value="Removing order from queue"/>
    </log>
</sequence>

当我调用API resource将订单插入 时queue，它可以工作。但是，当Message Processor消费时，它会注销

[2017-07-13 10:06:34,856] 警告 - JmsConsumer [orders_mb-C-1]。没有收到 javax.jms.ObjectMessage

我不知道出了什么问题，我看到这个问题询问了同样的问题，但是，我已经插入了强制性的属性，但它还没有在这里工作。

4

1 回答 1

0

尝试在阻塞模式下使用呼叫中介。

于 2017-07-28T14:56:39.007 回答