IBM Websphere MQ轉換爲Apache Apex操作員流？

Question

我一直在廣泛搜索INTERNET，以便在Apache Apex中使用web-sphere MQ將MQ消息流式傳輸到DAG中。但是，似乎沒有關於此事的IBM文檔。

我知道它可能與ActiveMQ類似，我可能只需要傳入Websphere Jars，但我不知道從哪裏開始。

@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

您是否看過運算符的測試用例，看看它是否有助於配置？

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

Answer 2

可以使用JMS輸入操作符從頂點（malhar）從IBM MQ系列閱讀，但你需要對JMS的MQ系列驅動器（V6）與兩個V6和V8服務器工作。我沒有一個方便的驅動程序的鏈接，但如果你找不到它，讓我知道，我會看看我能否找到它。