0

我一直在广泛搜索 INTERNET，以寻找一种在 Apache Apex 中使用 web-sphere MQ 将 MQ 消息流式传输到 DAG 的方法。但是，似乎没有关于此事的 IBM 文档。

我知道它可能类似于 ActiveMQ，我可能只需要传入 websphere jar，但是我不知道从哪里开始。

 @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);
  }
4

2 回答 2

0

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

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

于 2017-05-30T23:41:33.630 回答
0

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

于 2017-05-30T23:54:44.853 回答