2017-10-19 5 views
0

私のプロキシサービスで、JMS-ActiveMQでエンドポイントを作成しようとしていますが、URIで失敗します。私のJMSエンドポイントURIは正しいですか? tooling380でEI611でActiveMQを使用しています。WSO2 ESBエンドポイントjmsプロキシサービスでuri syntax-format

<?xml version="1.0" encoding="UTF-8"?> 
<proxy name="CSVProcessor" startOnLoad="true" transports="vfs" xmlns="http://ws.apache.org/ns/synapse"> 
<target> 
    <inSequence> 
     <log level="full"/> 
     <smooks config-key="smooks-config" description="GetSmooks"> 
      <input type="text"/> 
      <output type="xml"/> 
     </smooks> 
     <log description="GetData" level="full"/> 
     <datamapper config="gov:datamapper/NewConfig.dmc" description="MapPriceData" inputSchema="gov:datamapper/NewConfig_inputSchema.json" inputType="XML" outputSchema="gov:datamapper/NewConfig_outputSchema.json" outputType="XML"/> 
     <log description="LogDataMapper" level="full"/> 
     <property name="OUT_ONLY" scope="default" type="STRING" value="true"/> 
     <send> 
      <endpoint> 
       <address uri="jms:/foo.bar?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&amp;java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;java.naming.provider.url=tcp://localhost:61616&amp;transport.jms.DestinationType=queue"/> 
      </endpoint> 
     </send> 
    </inSequence> 
    <outSequence/> 
    <faultSequence/> 
</target> 
<parameter name="transport.PollInterval">5</parameter> 
<parameter name="transport.vfs.FileURI">file://c:\test-data\in</parameter> 
<parameter name="transport.vfs.ContentType">text/plain</parameter> 
<parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter> 
<parameter name="transport.vfs.MoveAfterFailure">file://c:\test-data\original</parameter> 
<parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter> 
<parameter name="transport.vfs.FileNamePattern">.*.csv</parameter> 
<parameter name="transport.vfs.MoveAfterProcess">file://c:\test-data\out</parameter> 
</proxy> 

エラー:

[2017年10月19日17:20:30944] [] ERROR - システムはJMSからの輸送情報を推測することができないClientUtils:/foo.bar輸送?。 jms.ConnectionFactoryJNDIName = QueueConnectionFactory & java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory & java.naming.provider.url = tcp:// localhost:61616 & transport.jms.DestinationType = queue URL。 [2017-10-19 17:20:30,948] [] ERROR - Axis2Senderメッセージの送信中に予期しないエラーが発生しました org.apache.axis2.AxisFault:システムはjms:/foo.bar?トランスポートからトランスポート情報を推測できません.jms.ConnectionFactoryJNDIName = QueueConnectionFactory & java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory & java.naming.provider.url = tcp:// localhost:61616 & transport.jms.DestinationType = queue URL。 at org.apache.axis2.description.ClientUtils.inferOutTransport(ClientUtils.java:81) (org.apache.axis2.client.OperationClient.prepareMessageContext(OperationClient.java:288) 、org.apache.axis2.description) org.apache.synapse.core.axis2.Axis2FlexibleMEPClient.sendでorg.apache.axis2.client.OperationClient.execute(OperationClient.java:149) でOutOnlyAxisOperationClient.executeImpl(OutOnlyAxisOperation.java:249) (Axis2FlexibleMEPClient.java: 595)ORGでorg.apache.synapse.core.axis2.Axis2SynapseEnvironment.send(Axis2SynapseEnvironment.java:548) でorg.apache.synapse.core.axis2.Axis2Sender.sendOn(Axis2Sender.java:83) で。 apache.synapse.endpoints.AbstractEndpoint.send(AbstractEndpoint.java:382) (AddressEndpoint.java:65) at org.apache.synapse.endpoints.AddressEndpoint.send(SendMediator.java:121) at org.apache.synapse.mediators .AbstractListMediator.mediate(AbstractListMediator.java:97) at org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:59) at org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.java :158) at org.apache.synapse.core.axis2.ProxyServiceMessageReceiver.receive(ProxyServiceMessageReceiver.java:213) at org.apache.axis2.engine.AxisEngine.receive(AxisEngine.java:180) at org.apache .axis2.transport.base.AbstractTransportListener.handleIncomingMessage(AbstractTransportListener.java:328) org.apache.synapse.transport.vfs.VFSTransportListener.processFile(VFSTransportListener.java:824) at org.apache.synapse.transport.vfs.VFSTransportListener.scanFileOrDirectory(VFSTransportListener.java:472) at org.apache.synapse .transport.vfs.VFSTransportListener.poll(VFSTransportListener.java:188) at org.apache.synapse.transport.vfs.VFSTransportListener.poll(VFSTransportListener.java:134) at org.apache.axis2.transport.base.AbstractPollingTransportListener $ 1 $ 1.run(AbstractPollingTransportListener.java:67) at org.apache.axis2.transport.base.threads.NativeWorkerPool $ 1.run(NativeWorkerPool.java:172) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor。 java:1149) at java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor。 WARN - EndpointContext Endpoint:アドレスがjms:/foo.barのAnonymousEndpoint?EndpointContext Endpoint:アドレスがjms:/foo.barのAnonymousEndpoint? transport.jms。ConnectionFactoryJNDIName = QueueConnectionFactory & java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory & java.naming.provider.url = tcp:// localhost:61616 & transport.jms.DestinationType = queueは次のようにサスペンドされます。それは失敗しました

+0

axis2.xmlとaxis2-client.xmlに関連するすべての設定を有効にしました。それでも同じエラー。 – MaMuDragon

答えて

1

これは私の悪かったです。

axis2.xmlの以下のエントリ(C:\ wso2ei-6.1.1 \ conf \ axis2)を完全にコメント解除していないため、このエラーが発生しました。私は先導<!--のコメントを外しましたが、末尾の-->はコメントしませんでした。確かに馬鹿です。コメント解除後

<transportSender name="jms" class="org.apache.axis2.transport.jms.JMSSender"/> 

、新しいXMLフォーマットにソースCSVファイルから変換されたデータは、所望に応じて、ActiveMQの宛先のJMSキューに送られました。

関連する問題