IBM Websphere MQ vers Apache Apex Opérateur Stream?

Question

J'ai beaucoup cherché sur Internet pour trouver une façon d'utiliser la MQ de la sphère Web dans Apache Apex pour diffuser le message MQ à travers et dans un DAG. Cependant, il semble qu'il n'y ait pas de documentation IBM à ce sujet.

Je sais qu'il pourrait être similaire à ActiveMQ et je pourrais avoir juste besoin de passer dans les Jars websphere, mais je ne sais pas par où commencer.

@Override 
    public void populateDAG(DAG dag, Configuration conf) 
    { 
    JMSStringInputOperator amqInput = dag.addOperator("amqIn", 
     new JMSStringInputOperator()); 

    LineOutputOperator out = dag.addOperator("fileOut", new LineOutputOperator()); 

    dag.addStream("data", amqInput.output, out.input); 
    } 

Answer 1

Avez-vous regardé le scénario de test de l'opérateur et avez-vous vu si cela vous aide à configurer?

https://github.com/apache/apex-malhar/blob/master/library/src/test/java/com/datatorrent/lib/io/jms/JMSStringInputOperatorTest.java

Answer 2

Vous pouvez utiliser les opérateurs d'entrée JMS d'Apex (malhar) pour lire de la série IBM MQ, mais vous avez besoin du pilote de la série MQ (v6) pour JMS qui fonctionne avec le serveur v6 et v8. Je n'ai pas de lien utile pour le pilote mais si vous ne le trouvez pas, faites le moi savoir et je verrai si je peux le trouver.