Point de terminaison WSO2 ESB jms format de syntaxe uri dans le service proxy

Question

Dans mon service proxy, j'essaie de créer un point de terminaison avec JMS-ActiveMQ et il échoue dans l'uri. Mon interface utilisateur JMS Endpoint est-elle correcte? J'utilise ActiveMQ avec EI611 sur tooling380.

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

Erreur:

[19/10/2017 17: 20: 30944] [] ERREUR - ClientUtils Le système ne peut pas déduire les informations de transport des jms: /foo.bar transport?. jms.ConnectionFactoryJNDIName = QueueConnectionFactory & java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory & java.naming.provider.url = tcp: // localhost: 61616 & transport.jms.DestinationType = URL de file d'attente. [2017-10-19 17: 20: 30,948] [] ERREUR - Axis2Sender Erreur inattendue lors de l'envoi d'un message org.apache.axis2.AxisFault: Le système ne peut pas déduire les informations de transport du transport 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 = URL de file d'attente. à org.apache.axis2.description.ClientUtils.inferOutTransport (ClientUtils.java:81) à org.apache.axis2.client.OperationClient.prepareMessageContext (OperationClient.java:288) à org.apache.axis2.description. OutOnlyAxisOperationClient.executeImpl (OutOnlyAxisOperation.java:249) à org.apache.axis2.client.OperationClient.execute (OperationClient.java:149) à org.apache.synapse.core.axis2.Axis2FlexibleMEPClient.send (Axis2FlexibleMEPClient.java: 595) à org.apache.synapse.core.axis2.Axis2Sender.sendOn (Axis2Sender.java:83) à org.apache.synapse.core.axis2.Axis2SynapseEnvironment.send (Axis2SynapseEnvironment.java:548) à org. apache.synapse.endpoints.AbstractEndpoint.send (AbstractEndpoint.java:382) à org.apache.synapse.endpoints.AddressEndpoint.send (AddressEndpoint.java:65) à org.apache.synapse.mediators.builtin.SendMediator.mediate (SendMediator.java:121) à org.apache.synapse.mediators .AbstractListMediator.mediate (AbstractListMediator.java:97) à org.apache.synapse.mediators.AbstractListMediator.mediate (AbstractListMediator.java:59) à org.apache.synapse.mediators.base.SequenceMediator.mediate (SequenceMediator.java : 158) à org.apache.synapse.core.axis2.ProxyServiceMessageReceiver.receive (ProxyServiceMessageReceiver.java:213) à 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) à org.apache.synapse.transport.vfs.VFSTransportListener.scanFileOrDirectory (VFSTransportListener.java:472) à org.apache.synapse .transport.vfs.VFSTransportListener.poll (VFSTransportListener.java:188) à org.apache.synapse.transport.vfs.VFSTransportListener.poll (VFSTransportListener.java:134) à org.apache.axis2.transport.base.AbstractPollingTransportListener $ 1 $ 1.run (AbstractPollingTransportListener.java:67) à org.apache.axis2.transport.base.threads.NativeWorkerPool $ 1.run (NativeWorkerPool.java:172) à java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor. java: 1149) at java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor. java: 624) at java.lang.Thread.run (Thread.java:748) [2017-10-19 17: 20: 30,958] [] AVERTISSEMENT - EndpointContext Endpoint: AnonymousEndpoint avec adresse jms: /foo.bar? transport.jms.ConnectionFactoryJNDIName = QueueConnectionFactory & java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory & java.naming.provider.url = tcp: // localhost: 61616 & transport.jms.DestinationType = file d'attente sera marquée comme SUSPENDUE il a échoué

Answer 1

Ok, c'était mon mauvais.

Je n'ai pas complètement décommenter l'entrée ci-dessous dans axis2.xml (dans C: \ wso2ei-6.1.1 \ conf \ axis2), ce qui a entraîné cette erreur. Je décommente le premier <!-- mais pas le -->. Suis un idiot, c'est sûr.

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

Après décommentant, les données transformées à partir du fichier CSV source dans un nouveau format XML, a été envoyé à la file d'attente de la destination de ActiveMQ, comme vous le souhaitez.