IBM Websphere MQ 到 Apache Apex Operator Stream？答案

【问题标题】：IBM Websphere MQ to Apache Apex Operator Stream?IBM Websphere MQ 到 Apache Apex Operator Stream？
【发布时间】：2017-05-22 19:07:45
【问题描述】：

我一直在广泛地搜索 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);
  }

【问题讨论】：

标签： java jms ibm-mq apache-apex

【解决方案1】：

您是否查看了操作员的测试用例，看看它是否有助于配置？

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

【讨论】：

【解决方案2】：

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

【讨论】：

IBM MQ v6 自 2012 年以来一直不受 IBM 支持，它可能可以工作，但如果出现问题，您将无法从 IBM 获得任何支持。