IBM Websphere MQ to Apache Apex Operator Stream?

Question

我一直在互联网上广泛搜索，寻找一种在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

您可以使用 Apex (malhar( 中的 JMS 输入运算符从 IBM MQ 系列读取数据，但您需要适用于 JMS 的 MQ 系列驱动程序 (v6(，它适用于 v6 和 v8 服务器。我没有方便司机的链接，但如果你找不到它，请告诉我，我会看看我是否能找到它。